Unsubscribe S3EchoUploader service from upload queue

isikhar · isikhar · commit 3e9aee35dede · 2024-10-15T09:21:27.000+01:00
diff --git a/src/dlstbx/services/s3echo_uploader.py b/src/dlstbx/services/s3echo_uploader.py
@@ -35,13 +35,13 @@ def initializing(self):
         """
         self.log.info(f"{S3EchoUploader._service_name} starting")
 
-        workflows.recipe.wrap_subscribe(
-            self._transport,
-            "s3echo.upload",
-            self.on_upload,
-            acknowledgement=True,
-            log_extender=self.extend_log,
-        )
+        # workflows.recipe.wrap_subscribe(
+        #    self._transport,
+        #    "s3echo.upload",
+        #    self.on_upload,
+        #    acknowledgement=True,
+        #    log_extender=self.extend_log,
+        # )
 
         workflows.recipe.wrap_subscribe(
             self._transport,
