diff --git a/taskiq/cli/scheduler/run.py b/taskiq/cli/scheduler/run.py index 742626b1..5b072e30 100644 --- a/taskiq/cli/scheduler/run.py +++ b/taskiq/cli/scheduler/run.py @@ -48,11 +48,12 @@ async def get_schedules(source: ScheduleSource) -> list[ScheduledTask]: try: return await source.get_schedules() except Exception as exc: - logger.warning( - "Cannot update schedules with source: %s", + logger.error( + "Cannot update schedules with source: %s\n%s{}", source, + exc, + exc_info=True, ) - logger.debug(exc, exc_info=True) return []