Fix linter error

alephdata · May 8, 2024 · e2fb94a · e2fb94a
1 parent 4de7e00
commit e2fb94a
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py
@@ -463,7 +463,9 @@ def handle(self, task: Task):
                     )
                 dataset.checkout_task(task.task_id, task.operation)
                 task.increment_retry_count(self.conn)
-                log.info(f"Dispatching task {task.task_id} from job {task.job_id} to worker {platform.node()}")
+                log.info(
+                    f"Dispatching task {task.task_id} from job {task.job_id} to worker {platform.node()}"
+                )
                 task = self.dispatch_task(task)
             else:
                 log.warn(f"Discarding task: {task.task_id}")
@@ -610,7 +612,7 @@ def get_rabbitmq_connection():
             pika.exceptions.AMQPConnectionError,
             pika.exceptions.AMQPError,
             ConnectionResetError,
-        )
+        ):
             log.exception(f"RabbitMQ error. Attempt: {attempt}")
         local.connection = None