[3000.8] Fix Runners in SSE (#173)

* Runners fix

* Rework runner fix

* Add changelog for sse fix

Author: dwoz

CHANGELOG.md

@@ -13,6 +13,7 @@ Fixed
 -----
 
 - Fix runners that broke when patching for CVE-2021-25281
+- Fix issue with runners in SSE
 
 Salt 3000.7 (2021-01-28)
 ========================

salt/client/mixins.py

@@ -450,7 +450,7 @@ class AsyncClientMixin(object):
     client = None
     tag_prefix = None
 
-    def _proc_function(self, fun, low, user, tag, jid, daemonize=True):
+    def _proc_function_remote(self, fun, low, user, tag, jid, daemonize=True):
         '''
         Run this method in a multiprocess target to execute the function on the
         master and fire the return data on the event bus
@@ -474,7 +474,7 @@ def _proc_function(self, fun, low, user, tag, jid, daemonize=True):
         except salt.exceptions.EauthAuthenticationError as exc:
             log.error(exc)
 
-    def _proc_function_local(self, fun, low, user, tag, jid, daemonize=True):
+    def _proc_function(self, fun, low, user, tag, jid, daemonize=True):
         '''
         Run this method in a multiprocess target to execute the function
         locally and fire the return data on the event bus
@@ -521,15 +521,15 @@ def _gen_async_pub(self, jid=None):
         tag = salt.utils.event.tagify(jid, prefix=self.tag_prefix)
         return {'tag': tag, 'jid': jid}
 
-    def asynchronous(self, fun, low, user="UNKNOWN", pub=None, local=False):
+    def asynchronous(self, fun, low, user="UNKNOWN", pub=None, local=True):
         '''
         Execute the function in a multiprocess and return the event tag to use
         to watch for the return
         '''
         if local:
-            proc_func = self._proc_function_local
-        else:
             proc_func = self._proc_function
+        else:
+            proc_func = self._proc_function_remote
         async_pub = pub if pub is not None else self._gen_async_pub()
         proc = salt.utils.process.SignalHandlingProcess(
             target=proc_func,

salt/wheel/__init__.py

@@ -123,8 +123,8 @@ def cmd_async(self, low):
             })
             {'jid': '20131219224744416681', 'tag': 'salt/wheel/20131219224744416681'}
         '''
-        fun = low.get('fun')
-        return self.asynchronous(fun, low)
+        fun = low.get("fun")
+        return self.asynchronous(fun, low, local=False)
 
     def cmd(self, fun, arg=None, pub_data=None, kwarg=None, print_event=True, full_return=False):  # pylint: disable=useless-super-delegation
         '''