Name the processes.

saltstack · Nov 30, 2019 · 6512a2f · 6512a2f
1 parent 86b1722
commit 6512a2f
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/salt/client/mixins.py b/salt/client/mixins.py
@@ -510,6 +510,7 @@ def asynchronous(self, fun, low, user='UNKNOWN', pub=None):
         async_pub = pub if pub is not None else self._gen_async_pub()
         proc = salt.utils.process.SignalHandlingProcess(
                 target=self._proc_function,
+                name='ProcessFunc',
                 args=(fun, low, user, async_pub['tag'], async_pub['jid']))
         with salt.utils.process.default_signals(signal.SIGINT, signal.SIGTERM):
             # Reset current signals before starting the process in

diff --git a/salt/metaproxy/proxy.py b/salt/metaproxy/proxy.py
@@ -726,7 +726,9 @@ def handle_decoded_payload(self, data):
             instance = None
         with default_signals(signal.SIGINT, signal.SIGTERM):
             process = SignalHandlingProcess(
-                target=self._target, args=(instance, self.opts, data, self.connected)
+                target=self._target,
+                name='ProcessPayload',
+                args=(instance, self.opts, data, self.connected)
             )
     else:
         process = threading.Thread(

diff --git a/salt/minion.py b/salt/minion.py
@@ -1525,7 +1525,9 @@ def _handle_decoded_payload(self, data):
                 instance = None
             with default_signals(signal.SIGINT, signal.SIGTERM):
                 process = SignalHandlingProcess(
-                    target=self._target, args=(instance, self.opts, data, self.connected)
+                    target=self._target,
+                    name='ProcessPayload',
+                    args=(instance, self.opts, data, self.connected)
                 )
         else:
             process = threading.Thread(