diff --git a/conductor/ConductorWorker.py b/conductor/ConductorWorker.py index 872fc36..c50b119 100644 --- a/conductor/ConductorWorker.py +++ b/conductor/ConductorWorker.py @@ -145,6 +145,9 @@ class ConductorWorker: activecount = threading.active_count() if expectedthreads != activecount: logging.getLogger("pyexec").fatal("!!! Active/expected running threads count is: %d/%d", activecount, expectedthreads) + if activecount == 1: + logging.getLogger("pyexec").fatal("!!! Exiting") + sys.exit(1) def exc(taskType, inputData, startTime, retryCount, status, callbackAfterSeconds, pollCount):