chore: ruff

Doist · Jul 30, 2024 · 1774834 · 1774834
1 parent 0f56ca0
commit 1774834
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/sqs_workers/queue.py b/sqs_workers/queue.py
@@ -94,7 +94,9 @@ def process_batch(self, wait_seconds: int = 0) -> BatchProcessingResult:
         the number of successfully processed messages, and exit
         """
         if self.batching_policy.batching_enabled:
-            messages = self.get_raw_messages(wait_seconds, self.batching_policy.batch_size)
+            messages = self.get_raw_messages(
+                wait_seconds, self.batching_policy.batch_size
+            )
             success = self.process_messages(messages)
             messages_with_success = ((m, success) for m in messages)
         else:
@@ -140,7 +142,9 @@ def _handle_processed(self, messages_with_success: Iterable[Tuple[Any, bool]]):
                         {
                             "Id": m.message_id,
                             "ReceiptHandle": m.receipt_handle,
-                            "VisibilityTimeout": self.backoff_policy.get_visibility_timeout(m),
+                            "VisibilityTimeout": self.backoff_policy.get_visibility_timeout(
+                                m
+                            ),
                         }
                     )