File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
src/aleph/vm/orchestrator Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change 77import time
88from pathlib import Path
99from statistics import mean
10- from typing import Callable
1110from typing import Callable , Optional , cast
1211
1312from aiohttp .web import Request , Response
@@ -239,8 +238,7 @@ async def fake_read() -> bytes:
239238 logger .info (f"BENCHMARK: n={ len (bench )} avg={ mean (bench ):03f} min={ min (bench ):03f} max={ max (bench ):03f} " )
240239 logger .info (bench )
241240
242- event = None
243- result = await run_code_on_event (vm_hash = ref , event = event , pubsub = PubSub (), pool = pool )
241+ result = await run_code_on_event (vm_hash = ref , event = None , pubsub = PubSub (), pool = pool )
244242 print ("Event result" , result )
245243
246244
@@ -251,7 +249,7 @@ async def start_instance(item_hash: ItemHash) -> None:
251249 # The main program uses a singleton pubsub instance in order to watch for updates.
252250 # We create another instance here since that singleton is not initialized yet.
253251 # Watching for updates on this instance will therefore not work.
254- pubsub = None
252+ pubsub : Optional [ PubSub ] = None
255253
256254 await start_persistent_vm (item_hash , pubsub , pool )
257255
You can’t perform that action at this time.
0 commit comments