From 1b278e08a2a683f987487ff7d4b7f8240edf8ab7 Mon Sep 17 00:00:00 2001 From: Hugo Herter Date: Thu, 14 Mar 2024 09:39:01 +0100 Subject: [PATCH] Fix typing: Invalid type annotations --- src/aleph/vm/orchestrator/cli.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/aleph/vm/orchestrator/cli.py b/src/aleph/vm/orchestrator/cli.py index 94b17d305..29b527def 100644 --- a/src/aleph/vm/orchestrator/cli.py +++ b/src/aleph/vm/orchestrator/cli.py @@ -7,7 +7,6 @@ import time from pathlib import Path from statistics import mean -from typing import Callable from typing import Callable, Optional, cast from aiohttp.web import Request, Response @@ -239,8 +238,7 @@ async def fake_read() -> bytes: logger.info(f"BENCHMARK: n={len(bench)} avg={mean(bench):03f} min={min(bench):03f} max={max(bench):03f}") logger.info(bench) - event = None - result = await run_code_on_event(vm_hash=ref, event=event, pubsub=PubSub(), pool=pool) + result = await run_code_on_event(vm_hash=ref, event=None, pubsub=PubSub(), pool=pool) print("Event result", result) @@ -251,7 +249,7 @@ async def start_instance(item_hash: ItemHash) -> None: # The main program uses a singleton pubsub instance in order to watch for updates. # We create another instance here since that singleton is not initialized yet. # Watching for updates on this instance will therefore not work. - pubsub = None + pubsub: Optional[PubSub] = None await start_persistent_vm(item_hash, pubsub, pool)