Remove unused loop params

Author: olethanh

src/aleph/vm/orchestrator/cli.py

@@ -188,8 +188,7 @@ async def fake_read() -> bytes:
 
     bench: list[float] = []
 
-    loop = asyncio.get_event_loop()
-    pool = VmPool(loop)
+    pool = VmPool()
     pool.setup()
 
     # Does not make sense in benchmarks
@@ -246,8 +245,7 @@ async def start_instance(item_hash: ItemHash, pubsub: Optional[PubSub], pool) ->
 async def run_instances(instances: list[ItemHash]) -> None:
     """Run instances from a list of message identifiers."""
     logger.info(f"Instances to run: {instances}")
-    loop = asyncio.get_event_loop()
-    pool = VmPool(loop)
+    pool = VmPool()
     # 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.

src/aleph/vm/orchestrator/supervisor.py

@@ -145,7 +145,7 @@ def run():
     engine = setup_engine()
     asyncio.run(create_tables(engine))
 
-    pool = VmPool(loop)
+    pool = VmPool()
     pool.setup()
 
     hostname = settings.DOMAIN_NAME

src/aleph/vm/pool.py

@@ -45,7 +45,7 @@ class VmPool:
     systemd_manager: SystemDManager
     creation_lock: asyncio.Lock
 
-    def __init__(self, loop: asyncio.AbstractEventLoop):
+    def __init__(self):
         self.counter = settings.START_ID_INDEX
         self.executions = {}
         self.message_cache = {}