Feature: Decompose submit notification for s3 to be able to patch it in extension (#11692)

maxhoheiser · web-flow · commit ff397dcb84ad · 2024-10-15T15:45:00.000+02:00
diff --git a/localstack-core/localstack/services/s3/notifications.py b/localstack-core/localstack/services/s3/notifications.py
@@ -845,7 +845,11 @@ def send_notifications(
             for config in configurations:
                 if notifier.should_notify(ctx, config):  # we check before sending it to the thread
                     LOG.debug("Submitting task to the executor for notifier %s", notifier)
-                    self.executor.submit(notifier.notify, ctx, config)
+                    self._submit_notification(notifier, ctx, config)
+
+    def _submit_notification(self, notifier, ctx, config):
+        "Required for patching submit with local thread context for EventStudio"
+        self.executor.submit(notifier.notify, ctx, config)
 
     def verify_configuration(
         self,
