deltaproxy

salt/metaproxy/deltaproxy.py

@@ -51,6 +51,7 @@
     SaltInvocationError,
     SaltSystemExit,
 )
+from salt.utils.decorators.arcanite_gestion import fire_started_event_job_wrapper
 from salt.minion import ProxyMinion
 from salt.utils.event import tagify
 from salt.utils.process import SignalHandlingProcess, default_signals
@@ -609,6 +610,7 @@ def target(cls, minion_instance, opts, data, connected, creds_map):
             ProxyMinion._thread_return(minion_instance, opts, data)
 
 
+@fire_started_event_job_wrapper
 def thread_return(cls, minion_instance, opts, data):
     """
     This method should be used as a threading target, start the actual
@@ -858,6 +860,7 @@ def thread_return(cls, minion_instance, opts, data):
                 log.exception("The return failed for job %s: %s", data["jid"], exc)
 
 
+@fire_started_event_job_wrapper
 def thread_multi_return(cls, minion_instance, opts, data):
     """
     This method should be used as a threading target, start the actual