subscribers: use shlex in the async-subscriber directly

rhodecode/apps/svn_support/__init__.py

@@ -48,7 +48,7 b' def includeme(config):'
 
         # If a reload command is set add a subscriber to execute it on
         # configuration changes.
-        reload_cmd = shlex.split(settings[config_keys.reload_command])
+        reload_cmd = settings[config_keys.reload_command]
         if reload_cmd:
             reload_timeout = settings[config_keys.reload_timeout] or None
             reload_subscriber = AsyncSubprocessSubscriber(

rhodecode/subscribers.py

@@ -18,6 +18,8 b''
 # RhodeCode Enterprise Edition, including its added features, Support services,
 # and proprietary license terms, please see https://rhodecode.com/licenses/
 import io
+import shlex
+
 import math
 import re
 import os
@@ -357,10 +359,16 b' class AsyncSubscriber(Subscriber):'
 class AsyncSubprocessSubscriber(AsyncSubscriber):
     """
     Subscriber that uses the subprocess32 module to execute a command if an
-    event is received. Events are handled asynchronously.
+    event is received. Events are handled asynchronously::
+
+        subscriber = AsyncSubprocessSubscriber('ls -la', timeout=10)
+        subscriber(dummyEvent) # running __call__(event)
+
     """
 
     def __init__(self, cmd, timeout=None):
+        if not isinstance(cmd, (list, tuple)):
+            cmd = shlex.split(cmd)
         super(AsyncSubprocessSubscriber, self).__init__()
         self._cmd = cmd
         self._timeout = timeout
@@ -384,6 +392,6 b' class AsyncSubprocessSubscriber(AsyncSub'
             log.exception('Error while executing command.')
             if e.output:
                 log.error('Command output: %s', e.output)
-        except:
+        except Exception:
             log.exception(
                 'Exception while executing command %s.', cmd)