@@ -129,9 +129,19 @@ async def delayed_send(
129
129
:param task: task to send.
130
130
:param delay: how long to wait.
131
131
"""
132
+ logger .debug (
133
+ "Waiting %d seconds before sending task %s with schedule_id %s." ,
134
+ delay ,
135
+ task .task_name ,
136
+ task .schedule_id ,
137
+ )
132
138
if delay > 0 :
133
139
await asyncio .sleep (delay )
134
- logger .info ("Sending task %s." , task .task_name )
140
+ logger .info (
141
+ "Sending task %s with schedule_id %s." ,
142
+ task .task_name ,
143
+ task .schedule_id ,
144
+ )
135
145
await scheduler .on_ready (source , task )
136
146
137
147
@@ -150,12 +160,13 @@ async def run_scheduler_loop(scheduler: TaskiqScheduler) -> None:
150
160
# We use this method to correctly sleep for one minute.
151
161
scheduled_tasks = await get_all_schedules (scheduler )
152
162
for source , task_list in scheduled_tasks .items ():
163
+ logger .debug ("Got %d schedules from source %s." , len (task_list ), source )
153
164
for task in task_list :
154
165
try :
155
166
task_delay = get_task_delay (task )
156
167
except ValueError :
157
168
logger .warning (
158
- "Cannot parse cron: %s for task: %s, schedule_id: %s" ,
169
+ "Cannot parse cron: %s for task: %s, schedule_id: %s. " ,
159
170
task .cron ,
160
171
task .task_name ,
161
172
task .schedule_id ,
@@ -171,6 +182,10 @@ async def run_scheduler_loop(scheduler: TaskiqScheduler) -> None:
171
182
minutes = 1 ,
172
183
)
173
184
delay = next_minute - datetime .now ()
185
+ logger .debug (
186
+ "Sleeping for %.2f seconds before getting schedules." ,
187
+ delay .total_seconds (),
188
+ )
174
189
await asyncio .sleep (delay .total_seconds ())
175
190
176
191
0 commit comments