Skip to content

Commit 60d76de

Browse files
Update taskiq/schedule_sources/label_based.py
Co-authored-by: Pavel Kirilin <s3riussan@gmail.com>
1 parent 4462985 commit 60d76de

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

taskiq/schedule_sources/label_based.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,10 @@ def post_send(self, scheduled_task: ScheduledTask) -> None:
6868
for task_name, task in self.broker.get_all_tasks().items():
6969
if task.broker != self.broker:
7070
# if task broker doesn't match self, something is probably wrong
71-
logger.warning(f"Broker for {task_name} ({task.broker}) doesn't match self ({self.broker})")
71+
logger.warning(
72+
f"Broker for {task_name} ({task.broker}) doesn't "
73+
f"match scheduler's broker ({self.broker})"
74+
)
7275
if scheduled_task.task_name != task_name:
7376
continue
7477

0 commit comments

Comments
 (0)