fix linter

Author: Renizmy

pycti/connector/opencti_connector_helper.py

@@ -765,11 +765,14 @@ def __init__(
         self.max_batches_per_minute = max_batches_per_minute
         if max_batches_per_minute is not None:
             from collections import deque
+
             self.batch_timestamps = deque()
         else:
             self.batch_timestamps = None
 
-    def _process_batch_and_update_state(self, batch, last_msg_id, trigger_reason="unknown"):
+    def _process_batch_and_update_state(
+        self, batch, last_msg_id, trigger_reason="unknown"
+    ):
         """Process a batch of messages and update connector state.
 
         This method handles:
@@ -820,7 +823,7 @@ def _process_batch_and_update_state(self, batch, last_msg_id, trigger_reason="un
                 "trigger_reason": trigger_reason,
                 "elapsed_time": elapsed,
                 "timestamp": time.time(),
-            }
+            },
         }
 
         self.callback(batch_data)
@@ -832,7 +835,7 @@ def _process_batch_and_update_state(self, batch, last_msg_id, trigger_reason="un
                 {
                     "batch_size": len(batch),
                     "trigger": trigger_reason,
-                }
+                },
             )
             self.exit_event.set()
             return False
@@ -884,10 +887,9 @@ def _wait_for_rate_limit(self, q):
                         "max_batches_per_minute": self.max_batches_per_minute,
                         "current_batch_count": len(self.batch_timestamps),
                         "wait_seconds": round(wait_time, 2),
-                    }
+                    },
                 )
 
-
                 chunk_size = 30.0
                 total_slept = 0.0
 
@@ -2316,7 +2318,7 @@ def listen_stream_batch(
             if max_batches_per_minute > 10000:
                 self.connector_logger.warning(
                     "Very high max_batches_per_minute configured",
-                    {"max_batches_per_minute": max_batches_per_minute}
+                    {"max_batches_per_minute": max_batches_per_minute},
                 )
 
         params = self._resolve_stream_parameters(
@@ -2334,9 +2336,7 @@ def listen_stream_batch(
         if max_batches_per_minute is not None:
             self.connector_logger.info(
                 "Batch rate limiting enabled",
-                {
-                    "max_batches_per_minute": max_batches_per_minute
-                }
+                {"max_batches_per_minute": max_batches_per_minute},
             )
 
         self._listen_stream_batch_thread = ListenStreamBatch(