test(logmanager): fix assert to wait log creation

Author: SQuent

app/managers/log_manager.py

@@ -39,6 +39,9 @@ def __init__(self):
         self._setup_handler(LogFormat.JSON)
         self.current_format = LogFormat.JSON
 
+        # Store references to automatic log tasks
+        self._automatic_log_tasks = []
+
         # Start automatic logging if enabled
         if os.getenv("ENABLE_AUTOMATIC_LOGS", "false").lower() == "true":
             self._start_automatic_logs()
@@ -89,17 +92,19 @@ def _start_automatic_logs(self):
         )
 
         # Create single log immediately
-        asyncio.create_task(
+        task_single = asyncio.create_task(
             self._create_single_log(log_data, getattr(logging, log_data.level.upper()))
         )
+        self._automatic_log_tasks.append(task_single)
 
         # Setup recurring logs if needed
         if log_data.interval and log_data.duration:
-            asyncio.create_task(
+            task_recurring = asyncio.create_task(
                 self._create_recurring_logs(
                     log_data, log_data.interval, log_data.duration
                 )
             )
+            self._automatic_log_tasks.append(task_recurring)
 
     async def create_log(self, log_data: LogRequest) -> dict | str:
         """Create log"""

tests/unit/test_log_manager.py

@@ -199,19 +199,19 @@ async def test_automatic_logs_initialization(self, monkeypatch, caplog):
         # Create manager with captured logs
         with caplog.at_level(logging.INFO, logger="app.managers.log_manager"):
             manager = LogManager()
-            # Wait a bit for the log to be created
-            await asyncio.sleep(0.1)
+            # Attendre explicitement la fin des tâches automatiques
+            if manager._automatic_log_tasks:
+                await asyncio.gather(*manager._automatic_log_tasks)
 
-        # Verify logs were created with correct configuration
         assert any(
             "Test auto message" in record.message for record in caplog.records
         ), "Expected log message not found in records"
         assert all(
-            record.levelname == "INFO" for record in caplog.records
+            record.levelname == "INFO" for record in caplog.records if "Test auto message" in record.message
         ), "Not all logs are at INFO level"
         assert all(
             hasattr(record, "service") and record.service == "test-service"
-            for record in caplog.records
+            for record in caplog.records if "Test auto message" in record.message
         ), "Service attribute missing or incorrect"
         assert isinstance(
             manager.logger.handlers[0].formatter, JsonFormatter