Do not share subprocess lock between instances

Signed-off-by: Aleksei Stepanov <penguinolog@gmail.com>

(cherry picked from commit 82da78d)
Signed-off-by: Aleksei Stepanov <penguinolog@gmail.com>

Author: penguinolog

doc/source/Subprocess.rst

@@ -18,9 +18,10 @@ API: Subprocess
         :type logger: logging.Logger
 
         .. versionchanged:: 1.2.0 log_mask_re regex rule for masking cmd
-        .. versionchanged:: 2.9.0 Not singleton anymore. Only lock is shared between all instances.
-        .. versionchanged:: 2.9.3 Logger can be enforced.
-        .. versionchanged:: 2.12.0 support chroot
+        .. versionchanged:: 3.1.0 Not singleton anymore. Only lock is shared between all instances.
+        .. versionchanged:: 3.2.0 Logger can be enforced.
+        .. versionchanged:: 4.1.0 support chroot
+        .. versionchanged:: 4.3.0 Lock is not shared anymore: allow parallel call of different instances
 
     .. py:attribute:: log_mask_re
 
@@ -54,7 +55,7 @@ API: Subprocess
         :rtype: typing.ContextManager
 
         .. Note:: Enter and exit main context manager is produced as well.
-        .. versionadded:: 2.12.0
+        .. versionadded:: 4.1.0
 
     .. py:method:: execute_async(command, stdin=None, open_stdout=True, open_stderr=True, verbose=False, log_mask_re=None, *, chroot_path=None, cwd=None, env=None, **kwargs)
 
@@ -84,7 +85,7 @@ API: Subprocess
 
         .. versionadded:: 1.2.0
         .. versionchanged:: 2.1.0 Use typed NamedTuple as result
-        .. versionchanged:: 2.9.3 Expose cwd and env as optional keyword-only arguments
+        .. versionchanged:: 3.2.0 Expose cwd and env as optional keyword-only arguments
 
     .. py:method:: execute(command, verbose=False, timeout=1*60*60, *, log_mask_re=None, stdin=None, **kwargs)
 
@@ -129,7 +130,7 @@ API: Subprocess
         :raises ExecHelperTimeoutError: Timeout exceeded
 
         .. note:: stdin channel is closed after the input processing
-        .. versionadded:: 2.9.4
+        .. versionadded:: 3.3.0
 
     .. py:method:: check_call(command, verbose=False, timeout=1*60*60, error_info=None, expected=(0,), raise_on_err=True, *, log_mask_re=None, stdin=None, exception_class=CalledProcessError, **kwargs)
 
@@ -160,8 +161,8 @@ API: Subprocess
 
         .. versionchanged:: 1.1.0 make method
         .. versionchanged:: 1.2.0 default timeout 1 hour
-        .. versionchanged:: 2.9.3 Exception class can be substituted
-        .. versionchanged:: 2.11.0 Expected is not optional, defaults os dependent
+        .. versionchanged:: 3.2.0 Exception class can be substituted
+        .. versionchanged:: 3.4.0 Expected is not optional, defaults os dependent
 
     .. py:method:: check_stderr(command, verbose=False, timeout=1*60*60, error_info=None, raise_on_err=True, *, expected=(0,), log_mask_re=None, stdin=None, exception_class=CalledProcessError, **kwargs)
 
@@ -192,8 +193,8 @@ API: Subprocess
 
         .. versionchanged:: 1.1.0 make method
         .. versionchanged:: 1.2.0 default timeout 1 hour
-        .. versionchanged:: 2.9.3 Exception class can be substituted
-        .. versionchanged:: 2.11.0 Expected is not optional, defaults os dependent
+        .. versionchanged:: 3.2.0 Exception class can be substituted
+        .. versionchanged:: 3.4.0 Expected is not optional, defaults os dependent
 
 
 .. py:class:: SubprocessExecuteAsyncResult
@@ -220,4 +221,4 @@ API: Subprocess
 
         ``datetime.datetime``
 
-        .. versionadded:: 2.11.0
+        .. versionadded:: 3.4.1

exec_helpers/metaclasses.py

@@ -35,7 +35,6 @@
 from exec_helpers import api
 from exec_helpers import exceptions
 from exec_helpers import exec_result
-from exec_helpers import metaclasses  # pylint: disable=unused-import
 
 
 # noinspection PyTypeHints
@@ -63,7 +62,7 @@ def stdout(self) -> typing.Optional[typing.IO]:  # type: ignore
         return super(SubprocessExecuteAsyncResult, self).stdout
 
 
-class Subprocess(api.ExecHelper, metaclass=metaclasses.SingleLock):
+class Subprocess(api.ExecHelper):
     """Subprocess helper with timeouts and lock-free FIFO."""
 
     def __init__(
@@ -83,8 +82,10 @@ def __init__(
         :type logger: logging.Logger
 
         .. versionchanged:: 1.2.0 log_mask_re regex rule for masking cmd
-        .. versionchanged:: 2.9.3 Not singleton anymore. Only lock is shared between all instances.
-        .. versionchanged:: 2.9.3 Logger can be enforced.
+        .. versionchanged:: 3.1.0 Not singleton anymore. Only lock is shared between all instances.
+        .. versionchanged:: 3.2.0 Logger can be enforced.
+        .. versionchanged:: 4.1.0 support chroot
+        .. versionchanged:: 4.3.0 Lock is not shared anymore: allow parallel call of different instances.
         """
         super(Subprocess, self).__init__(logger=logger, log_mask_re=log_mask_re)
 
@@ -238,8 +239,8 @@ def execute_async(  # pylint: disable=arguments-differ
 
         .. versionadded:: 1.2.0
         .. versionchanged:: 2.1.0 Use typed NamedTuple as result
-        .. versionchanged:: 2.9.3 Expose cwd and env as optional keyword-only arguments
-        .. versionchanged:: 2.12.0 support chroot
+        .. versionchanged:: 3.2.0 Expose cwd and env as optional keyword-only arguments
+        .. versionchanged:: 3.5.3 support chroot
         """
         cmd_for_log = self._mask_command(cmd=command, log_mask_re=log_mask_re)  # type: str
 

exec_helpers/subprocess_runner.py

@@ -64,7 +64,6 @@ def _extension(modpath):
     _extension("exec_helpers.constants"),
     _extension("exec_helpers.exceptions"),
     _extension("exec_helpers.exec_result"),
-    _extension("exec_helpers.metaclasses"),
     _extension("exec_helpers.proc_enums"),
     _extension("exec_helpers.ssh_auth"),
     _extension("exec_helpers.ssh_client"),