core:services:kraken: Reduce ext log job interval

Author: joaomariolago

core/services/kraken/kraken.py

@@ -165,6 +165,12 @@ async def kill_dangling_containers(self) -> None:
                 except Exception as e:
                     logger.warning(f"Dangling container {container_name} could not be removed: {e}")
 
+    async def check_extension_logs_task(self) -> None:
+        try:
+            await self.extension_log_publisher.sync_with_running_extensions()
+        except Exception as error:
+            logger.debug(f"Failed to sync extension log streams: {error}")
+
     async def start_starter_task(self) -> None:
         while self.is_running:
             await self.init_dead_extensions()
@@ -177,17 +183,10 @@ async def start_cleaner_task(self) -> None:
             await self.kill_invalid_extensions()
             await self.kill_dangling_containers()
             await self.cleanup_temporary_extensions()
+            await self.check_extension_logs_task()
 
             await asyncio.sleep(60)
 
-    async def start_extension_logs_task(self) -> None:
-        while self.is_running:
-            try:
-                await self.extension_log_publisher.sync_with_running_extensions()
-            except Exception as error:
-                logger.debug(f"Failed to sync extension log streams: {error}")
-            await asyncio.sleep(2)
-
     async def stop(self) -> None:
         self.is_running = False
         await self.extension_log_publisher.shutdown()

core/services/kraken/main.py

@@ -38,7 +38,6 @@ async def main() -> None:
     # Launch background tasks
     asyncio.create_task(kraken.start_cleaner_task())
     asyncio.create_task(kraken.start_starter_task())
-    asyncio.create_task(kraken.start_extension_logs_task())
     asyncio.create_task(jobs.start())
 
     await server.serve()