warn if task broker doesn't match self

Author: TheTechromancer

taskiq/schedule_sources/label_based.py

@@ -30,6 +30,7 @@ async def get_schedules(self) -> List["ScheduledTask"]:
         for task_name, task in self.broker.get_all_tasks().items():
             if task.broker != self.broker:
                 # if task broker doesn't match self, something is probably wrong
+                logger.warning(f"Broker for {task_name} ({task.broker}) doesn't match self ({self.broker})")
                 continue
             for schedule in task.labels.get("schedule", []):
                 if "cron" not in schedule and "time" not in schedule:
@@ -62,7 +63,10 @@ def post_send(self, scheduled_task: ScheduledTask) -> None:
             return  # it's scheduled task with cron label, do not remove this trigger.
 
         for task_name, task in self.broker.get_all_tasks().items():
-            if task.broker != self.broker or scheduled_task.task_name != task_name:
+            if task.broker != self.broker:
+                # if task broker doesn't match self, something is probably wrong
+                logger.warning(f"Broker for {task_name} ({task.broker}) doesn't match self ({self.broker})")
+            if scheduled_task.task_name != task_name:
                 continue
 
             schedule_list = task.labels.get("schedule", []).copy()