Добави логирование в работу worker loop

This commit is contained in:
2026-02-22 23:03:11 +03:00
parent 3293814898
commit 8d177b0fd1
2 changed files with 12 additions and 4 deletions

View File

@@ -81,9 +81,13 @@ class ConfigManager:
pass
async def _worker_loop(self) -> None:
while not self._halt.is_set():
await asyncio.to_thread(self.execute)
await asyncio.sleep(self.work_interval)
self.logger.warning("Worker loop started")
try:
while not self._halt.is_set():
await asyncio.to_thread(self.execute)
await asyncio.sleep(self.work_interval)
finally:
self.logger.warning("Worker loop stopped")
async def _periodic_update_loop(self) -> None:
while not self._halt.is_set():

View File

@@ -129,6 +129,7 @@ class ConfigManagerV2:
async def _worker_loop(self) -> None:
"""Вызывать execute() циклически до запроса остановки."""
logger.warning("Worker loop started")
logger.debug(f"Запускаем _worker_loop с интервалом {self.work_interval}")
worker = WorkerLoop(
execute=self.execute,
@@ -137,7 +138,10 @@ class ConfigManagerV2:
on_error=self._on_execute_error,
on_success=self._on_execute_success,
)
await worker.run()
try:
await worker.run()
finally:
logger.warning("Worker loop stopped")
async def _periodic_update_loop(self) -> None:
"""Периодически проверять файл конфига на обновления до остановки."""