diff --git a/shippers/es.py b/shippers/es.py index 3fa2a178..aa2c0de3 100644 --- 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])