From c48640f2cc5a4bb268140ab016d2a032145a7fd0 Mon Sep 17 00:00:00 2001 From: Nick Khitrov Date: Thu, 26 Feb 2026 04:09:39 +0300 Subject: [PATCH] feat: Change shutdown warning logs to info level --- taskiq/cli/scheduler/run.py | 2 +- taskiq/cli/worker/process_manager.py | 2 +- taskiq/cli/worker/run.py | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/taskiq/cli/scheduler/run.py b/taskiq/cli/scheduler/run.py index 5b072e30..60390538 100644 --- a/taskiq/cli/scheduler/run.py +++ b/taskiq/cli/scheduler/run.py @@ -414,7 +414,7 @@ async def run_scheduler(args: SchedulerArgs) -> None: skip_first_run=args.skip_first_run, ) except asyncio.CancelledError: - logger.warning("Shutting down scheduler.") + logger.info("Shutting down scheduler.") await scheduler.shutdown() for source in scheduler.sources: await source.shutdown() diff --git a/taskiq/cli/worker/process_manager.py b/taskiq/cli/worker/process_manager.py index c34090c5..22257e86 100644 --- a/taskiq/cli/worker/process_manager.py +++ b/taskiq/cli/worker/process_manager.py @@ -141,7 +141,7 @@ def _signal_handler(signum: int, _frame: Any) -> None: logger.debug(f"Got signal {signum}.") action_queue.put(action_to_send) - logger.warning("Workers are scheduled for shutdown.") + logger.info("Workers are scheduled for shutdown.") return _signal_handler diff --git a/taskiq/cli/worker/run.py b/taskiq/cli/worker/run.py index 51b92176..53cef7c0 100644 --- a/taskiq/cli/worker/run.py +++ b/taskiq/cli/worker/run.py @@ -41,7 +41,7 @@ async def shutdown_broker(broker: AsyncBroker, timeout: float) -> None: :param broker: current broker. :param timeout: maximum amount of time to shutdown the broker. """ - logger.warning("Shutting down the broker.") + logger.info("Shutting down the broker.") try: ret_val = await asyncio.wait_for(broker.shutdown(), timeout) # type: ignore if ret_val is not None: