debug

StackStorm · Aug 6, 2024 · 785a717 · 785a717
1 parent 93c36a4
commit 785a717
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/st2common/st2common/transport/publishers.py b/st2common/st2common/transport/publishers.py
@@ -97,10 +97,14 @@ def do_publish(connection, channel):
                         "content_encoding": "utf-8",
                     }
 
+                    def inner(**inner_kwargs):
+                        LOG.debug("%s.publish.do_publish.inner: %s", self.__class__.__name__, inner_kwargs)
+                        return producer.publish(**inner_kwargs)
+
                     retry_wrapper.ensured(
                         connection=connection,
                         obj=producer,
-                        to_ensure_func=producer.publish,
+                        to_ensure_func=inner,
                         **kwargs,
                     )