summaryrefslogtreecommitdiff
path: root/executors.py
diff options
context:
space:
mode:
authorScott Gasch <[email protected]>2022-06-02 08:23:18 -0700
committerScott Gasch <[email protected]>2022-06-02 08:23:18 -0700
commita0722abe80c416e0c174f3ff861566834402d43b (patch)
treeb80aaff7a143fc7eae3165d4174789a794d72f30 /executors.py
parent2a6d7810f85b88fb89d11d3e6be64f974ab77f97 (diff)
Initial stab at a smarter doc/unit/integration/coverage test runner.
Diffstat (limited to 'executors.py')
-rw-r--r--executors.py10
1 files changed, 8 insertions, 2 deletions
diff --git a/executors.py b/executors.py
index 9a73248..a9d25da 100644
--- a/executors.py
+++ b/executors.py
@@ -150,7 +150,10 @@ class ThreadExecutor(BaseExecutor):
workers = max_workers
elif 'executors_threadpool_size' in config.config:
workers = config.config['executors_threadpool_size']
- logger.debug('Creating threadpool executor with %d workers', workers)
+ if workers is not None:
+ logger.debug('Creating threadpool executor with %d workers', workers)
+ else:
+ logger.debug('Creating a default sized threadpool executor')
self._thread_pool_executor = fut.ThreadPoolExecutor(
max_workers=workers, thread_name_prefix="thread_executor_helper"
)
@@ -203,7 +206,10 @@ class ProcessExecutor(BaseExecutor):
workers = max_workers
elif 'executors_processpool_size' in config.config:
workers = config.config['executors_processpool_size']
- logger.debug('Creating processpool executor with %d workers.', workers)
+ if workers is not None:
+ logger.debug('Creating processpool executor with %d workers.', workers)
+ else:
+ logger.debug('Creating a default sized processpool executor')
self._process_executor = fut.ProcessPoolExecutor(
max_workers=workers,
)