We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 305e874 commit 4462985Copy full SHA for 4462985
taskiq/schedule_sources/label_based.py
@@ -30,7 +30,10 @@ async def get_schedules(self) -> List["ScheduledTask"]:
30
for task_name, task in self.broker.get_all_tasks().items():
31
if task.broker != self.broker:
32
# if task broker doesn't match self, something is probably wrong
33
- logger.warning(f"Broker for {task_name} ({task.broker}) doesn't match self ({self.broker})")
+ logger.warning(
34
+ f"Broker for {task_name} ({task.broker}) doesn't "
35
+ f"match scheduler's broker ({self.broker})"
36
+ )
37
continue
38
for schedule in task.labels.get("schedule", []):
39
if "cron" not in schedule and "time" not in schedule:
0 commit comments