remote/coordinator: store event loop in loop attribute

Instead of using asyncio.get_event_loop() in various places in the
Coordinator class, store it in an attribute called loop.

Signed-off-by: Bastian Krause <[email protected]>

Author: Bastian-Krause

labgrid/remote/coordinator.py

@@ -194,7 +194,8 @@ def __init__(self) -> None:
         self.clients: dict[str, ClientSession] = {}
         self.load()
 
-        self.poll_task = asyncio.get_event_loop().create_task(self.poll())
+        self.loop = asyncio.get_event_loop()
+        self.poll_task = self.loop.create_task(self.poll())
 
     async def _poll_step(self):
         # save changes
@@ -216,8 +217,7 @@ async def _poll_step(self):
             traceback.print_exc()
 
     async def poll(self):
-        loop = asyncio.get_event_loop()
-        while not loop.is_closed():
+        while not self.loop.is_closed():
             try:
                 await asyncio.sleep(15.0)
                 await self._poll_step()
@@ -247,11 +247,10 @@ async def save(self):
         places = yaml.dump(places)
         places = places.encode()
 
-        loop = asyncio.get_event_loop()
         logging.debug("Awaiting resources")
-        await loop.run_in_executor(None, atomic_replace, "resources.yaml", resources)
+        await self.loop.run_in_executor(None, atomic_replace, "resources.yaml", resources)
         logging.debug("Awaiting places")
-        await loop.run_in_executor(None, atomic_replace, "places.yaml", places)
+        await self.loop.run_in_executor(None, atomic_replace, "places.yaml", places)
 
     def load(self):
         try:
@@ -310,7 +309,7 @@ async def request_task():
             except Exception:
                 logging.exception("error in client message handler")
 
-        runnning_request_task = asyncio.get_event_loop().create_task(request_task())
+        runnning_request_task = self.loop.create_task(request_task())
 
         try:
             async for out_msg in queue_as_aiter(out_msg_queue):
@@ -406,7 +405,7 @@ async def request_task():
             except Exception:
                 logging.exception("error in exporter message handler")
 
-        runnning_request_task = asyncio.get_event_loop().create_task(request_task())
+        runnning_request_task = self.loop.create_task(request_task())
 
         try:
             async for cmd in queue_as_aiter(command_queue):