fix: passing in attributes to exception

gregfurman · gregfurman · commit fc602004dab8 · 2025-02-25T19:15:41.000+02:00
diff --git a/localstack-core/localstack/services/lambda_/event_source_mapping/esm_worker.py b/localstack-core/localstack/services/lambda_/event_source_mapping/esm_worker.py
@@ -158,13 +158,12 @@ def poller_loop(self, *args, **kwargs):
                 poll_interval_duration = POLL_INTERVAL_SEC
             except EmptyPollResultsException as miss_ex:
                 # If the event source is empty, backoff
-                poll_miss_boff_duration = empty_boff.next_backoff()
+                poll_interval_duration = empty_boff.next_backoff()
                 LOG.debug(
-                    "The event source %s is empty. Backing off for for %s seconds until next request.",
+                    "The event source %s is empty. Backing off for %s seconds until next request.",
                     miss_ex.source_arn,
-                    poll_miss_boff_duration,
+                    poll_interval_duration,
                 )
-                poll_interval_duration = empty_boff.next_backoff()
             except Exception as e:
                 LOG.error(
                     "Error while polling messages for event source %s: %s",
diff --git a/localstack-core/localstack/services/lambda_/event_source_mapping/pollers/poller.py b/localstack-core/localstack/services/lambda_/event_source_mapping/pollers/poller.py
@@ -19,8 +19,9 @@ class EmptyPollResultsException(Exception):
     service: str
     source_arn: str
 
-    def __init__(self, *args, service: str = "", source_arn: str = ""):
-        super(EmptyPollResultsException, self).__init__(*args)
+    def __init__(self, service: str = "", source_arn: str = ""):
+        self.service = service
+        self.source_arn = source_arn
 
 
 class PipeStateReasonValues(PipeStateReason):
diff --git a/localstack-core/localstack/services/lambda_/event_source_mapping/pollers/sqs_poller.py b/localstack-core/localstack/services/lambda_/event_source_mapping/pollers/sqs_poller.py
@@ -133,11 +133,7 @@ def poll_events(self) -> None:
                     exc_info=LOG.isEnabledFor(logging.DEBUG),
                 )
         else:
-            raise EmptyPollResultsException(
-                "No results found in poll call to SQS",
-                service="sqs",
-                source_arn=self.source_arn,
-            )
+            raise EmptyPollResultsException(service="sqs", source_arn=self.source_arn)
 
     def handle_messages(self, messages):
         polled_events = transform_into_events(messages)
