From 5a3275dfb5138f574fff24df5b06b35081dfc2e8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Gremaud?= Date: Fri, 15 Sep 2023 12:05:37 +0200 Subject: [PATCH] deltaproxy --- salt/metaproxy/deltaproxy.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/salt/metaproxy/deltaproxy.py b/salt/metaproxy/deltaproxy.py index aacc4a336a23..70d4e8f2435d 100644 --- a/salt/metaproxy/deltaproxy.py +++ b/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