diff --git a/taskiq/cli/scheduler/run.py b/taskiq/cli/scheduler/run.py
index 80019654..315dc113 100644
--- a/taskiq/cli/scheduler/run.py
+++ b/taskiq/cli/scheduler/run.py
@@ -212,4 +212,6 @@ async def run_scheduler(args: SchedulerArgs) -> None:
     except asyncio.CancelledError:
         logger.warning("Shutting down scheduler.")
         await scheduler.shutdown()
+        for source in scheduler.sources:
+            await source.shutdown()
         logger.info("Scheduler shut down. Good bye!")