diff --git a/pycti/connector/opencti_connector_helper.py b/pycti/connector/opencti_connector_helper.py index f695b72a..ca0f4c5c 100644 --- a/pycti/connector/opencti_connector_helper.py +++ b/pycti/connector/opencti_connector_helper.py @@ -1779,7 +1779,6 @@ def _send_bundle(self, channel, bundle, **kwargs) -> None: sequence = kwargs.get("sequence", 0) update = kwargs.get("update", False) entities_types = kwargs.get("entities_types", None) - retry = kwargs.get("retry", 0) if entities_types is None: entities_types = [] @@ -1820,10 +1819,8 @@ def _send_bundle(self, channel, bundle, **kwargs) -> None: except (UnroutableError, NackError): self.connector_logger.error("Unable to send bundle, retry...") self.metric.inc("error_count") - retry = retry + 1 - if retry < 5: - kwargs.setdefault("retry", retry) - self._send_bundle(channel, bundle, **kwargs) + time.sleep(10) + self._send_bundle(channel, bundle, **kwargs) def stix2_get_embedded_objects(self, item) -> Dict: """gets created and marking refs for a stix2 item