Fix formatter v2

elastic · Jun 12, 2024 · 818b997 · 818b997
1 parent 148cbd6
commit 818b997
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/shippers/es.py b/shippers/es.py
@@ -21,6 +21,7 @@
 _EVENT_SENT = "_EVENT_SENT"
 _VERSION_CONFLICT = 409
 
+
 class JSONSerializer(Serializer):
     mimetype = "application/json"
 
@@ -165,10 +166,10 @@ def _handle_outcome(self, errors: tuple[int, Union[int, list[Any]]]) -> None:
                 "elasticsearch shipper", extra={"error": error["create"]["error"], "_id": error["create"]["_id"]}
             )
 
-            if "status" in error["create"] and  error["create"]["status"] == _VERSION_CONFLICT:
+            if "status" in error["create"] and error["create"]["status"] == _VERSION_CONFLICT:
                 # Skip duplicate events on replay queue
                 continue
-             
+
             shared_logger.debug("elasticsearch shipper", extra={"action": action_failed[0]})
             if self._replay_handler is not None:
                 self._replay_handler("elasticsearch", self._replay_args, action_failed[0])