We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent dde2189 commit 398b513Copy full SHA for 398b513
1 file changed
src/dlstbx/services/s3echo_uploader.py
@@ -35,13 +35,13 @@ def initializing(self):
35
"""
36
self.log.info(f"{S3EchoUploader._service_name} starting")
37
38
- # workflows.recipe.wrap_subscribe(
39
- # self._transport,
40
- # "s3echo.upload",
41
- # self.on_upload,
42
- # acknowledgement=True,
43
- # log_extender=self.extend_log,
44
- # )
+ workflows.recipe.wrap_subscribe(
+ self._transport,
+ "s3echo.upload",
+ self.on_upload,
+ acknowledgement=True,
+ log_extender=self.extend_log,
+ )
45
46
workflows.recipe.wrap_subscribe(
47
self._transport,
0 commit comments