goodboy
/
tractor
1
0
Fork 2
Code Issues 5 Pull Requests 6 Packages Projects Releases Wiki Activity

Only use `greenback` if actor-runtime is up..

shielded_ctx_cancel
Tyler Goodlet 2024-01-02 11:28:02 -05:00
parent ce7b8a5e18
commit fdf3a1b01b
1 changed files with 25 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
tractor/devx/_debug.py
View File

@ -682,7 +682,7 @@ async def pause(
https://en.wikipedia.org/wiki/Breakpoint https://en.wikipedia.org/wiki/Breakpoint
''' '''
__tracebackhide__ = True # __tracebackhide__ = True
actor = tractor.current_actor() actor = tractor.current_actor()
pdb, undo_sigint = mk_mpdb() pdb, undo_sigint = mk_mpdb()
task_name = trio.lowlevel.current_task().name task_name = trio.lowlevel.current_task().name
@ -836,25 +836,32 @@ async def pause(
# runtime aware version which takes care of all . # runtime aware version which takes care of all .
def pause_from_sync() -> None: def pause_from_sync() -> None:
print("ENTER SYNC PAUSE") print("ENTER SYNC PAUSE")
try: actor: tractor.Actor = tractor.current_actor(
import greenback err_on_no_runtime=False,
__tracebackhide__ = True )
if actor:
try:
import greenback
# __tracebackhide__ = True
actor: tractor.Actor = tractor.current_actor()
# task_can_release_tty_lock = trio.Event()
# spawn bg task which will lock out the TTY, we poll # task_can_release_tty_lock = trio.Event()
# just below until the release event is reporting that task as
# waiting.. not the most ideal but works for now ;) # spawn bg task which will lock out the TTY, we poll
greenback.await_( # just below until the release event is reporting that task as
actor._service_n.start(partial( # waiting.. not the most ideal but works for now ;)
pause, greenback.await_(
debug_func=None, actor._service_n.start(partial(
# release_lock_signal=task_can_release_tty_lock, pause,
)) debug_func=None,
) # release_lock_signal=task_can_release_tty_lock,
except ModuleNotFoundError: ))
log.warning('NO GREENBACK FOUND') )
except ModuleNotFoundError:
log.warning('NO GREENBACK FOUND')
else:
log.warning('Not inside actor-runtime')
db, undo_sigint = mk_mpdb() db, undo_sigint = mk_mpdb()
Lock.local_task_in_debug = 'sync' Lock.local_task_in_debug = 'sync'