ruffed

Author: TheTechromancer

taskiq/abc/broker.py

@@ -518,7 +518,8 @@ def _register_task(
         By default we register tasks in local task registry.
         But this behaviour can be changed in subclasses.
 
-        This method may raise TaskRejectedError if task has already been registered to a different broker.
+        This method may raise TaskRejectedError if task has already been
+        registered to a different broker.
 
         :param task_name: Name of a task.
         :param task: Decorated task.

taskiq/schedule_sources/label_based.py

@@ -31,8 +31,8 @@ async def get_schedules(self) -> List["ScheduledTask"]:
             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 "
-                	f"match scheduler's broker ({self.broker})"
+                    f"Broker for {task_name} ({task.broker}) doesn't "
+                    f"match scheduler's broker ({self.broker})",
                 )
                 continue
             for schedule in task.labels.get("schedule", []):
@@ -69,8 +69,8 @@ def post_send(self, scheduled_task: ScheduledTask) -> None:
             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 "
-                	f"match scheduler's broker ({self.broker})"
+                    f"Broker for {task_name} ({task.broker}) doesn't "
+                    f"match scheduler's broker ({self.broker})",
                 )
             if scheduled_task.task_name != task_name:
                 continue