We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f991b19 commit 3509bc9Copy full SHA for 3509bc9
cadence/async/event_loop.py
@@ -1,10 +1,10 @@
1
2
3
-from asyncio import AbstractEventLoop
+from asyncio import AbstractEventLoop, BaseEventLoop, EventLoop
4
from asyncio import Future
5
import asyncio
6
7
-class EventLoop(AbstractEventLoop):
+class EventLoop(BaseEventLoop):
8
__running = False
9
10
def __init__(self):
@@ -33,6 +33,11 @@ async def delay_print(message, delay):
33
print(message)
34
35
36
+class DeterministicRunner():
37
+ runner = None
38
+
39
+ def run_util_block
40
41
if __name__ == "__main__":
42
print("Starting workflow")
43
loop = asyncio.new_event_loop()
0 commit comments