feat(tradein/scheduler): cooperative SIGTERM-drain — in-flight scrape unit commits before exit (phase 2) #2070

Merged
lekss361 merged 3 commits from feat/tradein-scheduler-graceful-drain into main 2026-06-28 17:20:12 +00:00
Showing only changes of commit 6f76b565e5 - Show all commits

View file

@ -89,6 +89,9 @@ async def _await_scheduler(task: asyncio.Task[None]) -> None:
if task.done():
# Задача вышла сама (drained на checkpoint'е; без сигнала сюда не попадаем).
# .result() пробрасывает реальное исключение, если scheduler_loop неожиданно
# упал (сохраняем прежнюю loud-crash семантику `await task`), а не глушит его.
task.result()
logger.info("scheduler_main: scheduler task exited cleanly")
return