feat: Change shutdown warning logs to info level (#596)

Author: nkhitrov

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()

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
 

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: