fix(webhooks): prevent raise on give up

api/integrations/rudderstack/rudderstack.py

@@ -1,7 +1,7 @@
 import logging
 import typing
 
-import rudder_analytics
+from rudderstack import analytics as rudder_analytics
 
 from environments.identities.models import Identity
 from environments.identities.traits.models import Trait

api/pyproject.toml

@@ -46,9 +46,9 @@ readme = "readme.md"
 [tool.poetry.dependencies]
 python = ">=3.10,<3.12"
 django = "~3.2.23"
-rudder-sdk-python = "~1.0.5"
-analytics-python = "~1.4.0"
-backoff = "~1.10.0"
+rudder-sdk-python = "~2.0.2"
+segment-analytics-python = "~2.2.3"
+backoff = "~2.2.1"
 appdirs = "~1.4.4"
 django-cors-headers = "~3.5.0"
 djangorestframework = "~3.12.1"

api/tests/unit/webhooks/test_unit_webhooks.py

@@ -5,6 +5,7 @@
 from unittest import TestCase, mock
 
 import pytest
+import responses
 from core.constants import FLAGSMITH_SIGNATURE_HEADER
 from pytest_django.fixtures import SettingsWrapper
 from pytest_mock import MockerFixture
@@ -21,6 +22,7 @@
     WebhookEventType,
     WebhookType,
     call_environment_webhooks,
+    call_integration_webhook,
     call_organisation_webhooks,
     call_webhook_with_failure_mail_after_retries,
     trigger_sample_webhook,
@@ -316,3 +318,21 @@ def test_call_webhook_with_failure_mail_after_retries_does_not_retry_if_not_usin
     # Then
     assert requests_post_mock.call_count == 1
     send_failure_email_mock.assert_called_once()
+
+
+@responses.activate()
+def test_call_integration_webhook_does_not_raise_error_on_backoff_give_up(
+    mocker: MockerFixture,
+) -> None:
+    # Given
+    url = "https://test.com/webhook"
+    config = mocker.MagicMock(secret=None, url=url)
+
+    responses.add(url=url, method="POST", body=json.dumps({}), status=400)
+
+    # When
+    result = call_integration_webhook(config, data={})
+
+    # Then
+    # we don't get a result from the function, but no exception is raised
+    assert result is None

api/webhooks/webhooks.py

@@ -143,6 +143,8 @@ def trigger_sample_webhook(
     wait_gen=backoff.expo,
     exception=requests.exceptions.RequestException,
     max_tries=settings.WEBHOOK_BACKOFF_RETRIES,
+    raise_on_giveup=False,
+    giveup_log_level=logging.WARNING,
 )
 def _call_webhook(
     webhook: AbstractBaseWebhookModel,