Fix: Properties were initialized with a global object

src/aleph/vm/hypervisors/qemu/qemuvm.py

@@ -21,6 +21,7 @@ class QemuVM:
     mem_size_mb: int
     interface_name: str
     qemu_process = None
+    log_queues: list[asyncio.Queue]
 
     def __repr__(self) -> str:
         if self.qemu_process:
@@ -37,6 +38,7 @@ def __init__(self, config: QemuVMConfiguration):
         self.vcpu_count = config.vcpu_count
         self.mem_size_mb = config.mem_size_mb
         self.interface_name = config.interface_name
+        self.log_queues = []
 
     def prepare_start(self):
         pass
@@ -94,8 +96,6 @@ async def start(
         logger.debug(f"started qemu vm {self}, {proc}")
         return proc
 
-    log_queues: list[asyncio.Queue] = []
-
     # TODO : convert when merging with log fixing branch
     async def _process_stderr(self):
         while not self.qemu_process:

src/aleph/vm/pool.py

@@ -39,7 +39,7 @@ class VmPool:
 
     counter: int  # Used to provide distinct ids to network interfaces
     executions: dict[ItemHash, VmExecution]
-    message_cache: dict[str, ExecutableMessage] = {}
+    message_cache: dict[str, ExecutableMessage]
     network: Optional[Network]
     snapshot_manager: Optional[SnapshotManager] = None
     systemd_manager: SystemDManager
@@ -48,6 +48,7 @@ class VmPool:
     def __init__(self, loop: asyncio.AbstractEventLoop):
         self.counter = settings.START_ID_INDEX
         self.executions = {}
+        self.message_cache = {}
 
         asyncio.set_event_loop(loop)
         self.creation_lock = asyncio.Lock()