Add longer timeout on brokerd ctx cancel; seems to work?

master
Tyler Goodlet 2023-05-22 00:16:58 -04:00
parent c6da09f3c6
commit 53003618cb
1 changed files with 8 additions and 1 deletions

View File

@ -209,7 +209,14 @@ def sync(
) )
console.print(summary) console.print(summary)
await brokerd_ctx.cancel()
# exit via ctx cancellation.
await brokerd_ctx.cancel(timeout=1)
# TODO: once ported to newer tractor branch we should
# be able to do a loop like this:
# while brokerd_ctx.cancel_called_remote is None:
# await trio.sleep(0.01)
# await brokerd_ctx.cancel()
await portal.cancel_actor() await portal.cancel_actor()