++

phlop/proc.py

@@ -9,8 +9,7 @@
 from phlop.procs.runtimer import RunTimer
 
 
-class ProcessNonZeroExitCode(RuntimeError):
-    ...
+class ProcessNonZeroExitCode(RuntimeError): ...
 
 
 def run(cmd, shell=True, capture_output=True, check=False, print_cmd=True, **kwargs):

phlop/testing/parallel_processor.py

@@ -9,13 +9,14 @@
 from enum import Enum
 from multiprocessing import Process, Queue, cpu_count
 
+from phlop.logger import getLogger
 from phlop.proc import run
 
-timeout = 60  # seconds - give chance to interrupt
+timeout = 60 * 60  # seconds - give chance to interrupt
+logger = getLogger(__name__)
 
 
-class TestCaseFailure(Exception):
-    ...
+class TestCaseFailure(Exception): ...
 
 
 class LoggingMode(Enum):
@@ -114,7 +115,7 @@ def waiter(queue):
             try:
                 proc = queue.get(timeout=timeout)
             except Exception:
-                print("Queue Exception! - no jobs finished - polling")
+                logger.info("Queue timeout - polling")
                 continue
 
             time.sleep(0.01)  # don't throttle!

sh/lint.sh

@@ -7,7 +7,7 @@ set -e
 
 PY_FILES=$(find . -name "*.py")
 
-# python3 -m black phlop tests
+python3 -m black phlop tests
 pylint --errors-only phlop tests
 isort phlop tests
 python3 -m ruff check phlop tests