Test pytest

Author: =

.github/workflows/python-package.yml

@@ -26,7 +26,7 @@ jobs:
     - name: Install dependencies
       run: |
         python -m pip install --upgrade pip
-        python -m pip install flake8 pytest
+        python -m pip install flake8 pytest pytest-asyncio
         if [ -f requirements.txt ]; then pip install -r requirements.txt; fi
     - name: Lint with flake8
       run: |

ThreadPoolExecutorPlus/thread.py

@@ -165,13 +165,25 @@ def run(self):
             _base.LOGGER.critical('Exception in worker', exc_info=True)
 
 
+
 class _CustomWeakSet(weakref.WeakSet):
 
     def __repr__(self):
         return repr(self.data)
 
 
-class BrokenThreadPool(_base.BrokenExecutor):
+class BrokenExecutor(RuntimeError):
+    """
+    Raised when a executor has become non-functional after a severe failure.
+    """
+
+# Upward Compatible
+_class_brokenexecutor = BrokenExecutor
+if 'BrokenExecutor' in dir(_base):
+    _class_brokenexecutor = _base.BrokenExecutor
+
+
+class BrokenThreadPool(_class_brokenexecutor):
     """
     Raised when a worker thread in a ThreadPoolExecutor failed initializing.
     """
@@ -308,4 +320,4 @@ def shutdown(self, wait=True):
         if wait:
             for t in self._threads:
                 t.join()
-    shutdown.__doc__ = _base.Executor.shutdown.__doc__
+    shutdown.__doc__ = _base.Executor.shutdown.__doc__

tests/test_immport.py

@@ -1,8 +1,9 @@
 import os , sys
-o_path = os.getcwd()
-sys.path.append(os.path.split(o_path)[0])
+sys.path.append(os.getcwd())
 import pytest
 from ThreadPoolExecutorPlus import *
 
+@pytest.mark.asyncio
 async def test_import():
+    ThreadPoolExecutor()
     ...