From 4d5a9788dc4ef470879c9d6c1914f3b35e09f749 Mon Sep 17 00:00:00 2001 From: Jan Janssen Date: Mon, 21 Jul 2025 14:57:15 +0200 Subject: [PATCH 1/5] warn about max workers --- executorlib/standalone/inputcheck.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/executorlib/standalone/inputcheck.py b/executorlib/standalone/inputcheck.py index 2ebe6808..2a375941 100644 --- a/executorlib/standalone/inputcheck.py +++ b/executorlib/standalone/inputcheck.py @@ -3,6 +3,7 @@ import os.path from concurrent.futures import Executor from typing import Callable, Optional +from warnings import warn def check_oversubscribe(oversubscribe: bool) -> None: @@ -190,7 +191,9 @@ def validate_number_of_cores( "Block allocation requires a fixed set of computational resources. Neither max_cores nor max_workers are defined." ) else: - return multiprocessing.cpu_count() + max_workers = multiprocessing.cpu_count() + warn("max_workers parameter is not set, set default based on CPU count to: max_workers=" + str(max_workers)) + return def check_file_exists(file_name: Optional[str]): From c1c003984d218cb1a23d9b6b76243e80f34dd940 Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Mon, 21 Jul 2025 12:59:08 +0000 Subject: [PATCH 2/5] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- executorlib/standalone/inputcheck.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/executorlib/standalone/inputcheck.py b/executorlib/standalone/inputcheck.py index 2a375941..c2c97c8f 100644 --- a/executorlib/standalone/inputcheck.py +++ b/executorlib/standalone/inputcheck.py @@ -192,7 +192,10 @@ def validate_number_of_cores( ) else: max_workers = multiprocessing.cpu_count() - warn("max_workers parameter is not set, set default based on CPU count to: max_workers=" + str(max_workers)) + warn( + "max_workers parameter is not set, set default based on CPU count to: max_workers=" + + str(max_workers) + ) return From fbd71af7deb504164143b5eb83babda3d71c7b8d Mon Sep 17 00:00:00 2001 From: Jan Janssen Date: Mon, 21 Jul 2025 15:01:49 +0200 Subject: [PATCH 3/5] fix return --- executorlib/standalone/inputcheck.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/executorlib/standalone/inputcheck.py b/executorlib/standalone/inputcheck.py index 2a375941..d4cd9048 100644 --- a/executorlib/standalone/inputcheck.py +++ b/executorlib/standalone/inputcheck.py @@ -193,7 +193,7 @@ def validate_number_of_cores( else: max_workers = multiprocessing.cpu_count() warn("max_workers parameter is not set, set default based on CPU count to: max_workers=" + str(max_workers)) - return + return max_workers def check_file_exists(file_name: Optional[str]): From 3f98455829c9d5735de623c307dceaa8f394b520 Mon Sep 17 00:00:00 2001 From: Jan Janssen Date: Mon, 21 Jul 2025 15:28:07 +0200 Subject: [PATCH 4/5] Set stacklevel --- executorlib/standalone/inputcheck.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/executorlib/standalone/inputcheck.py b/executorlib/standalone/inputcheck.py index 29de12eb..cfaa2479 100644 --- a/executorlib/standalone/inputcheck.py +++ b/executorlib/standalone/inputcheck.py @@ -194,7 +194,8 @@ def validate_number_of_cores( max_workers = multiprocessing.cpu_count() warn( "max_workers parameter is not set, set default based on CPU count to: max_workers=" - + str(max_workers) + + str(max_workers), + stacklevel=2 ) return max_workers From 8fee4c484b6dfb16e8cefe602500bb6d53c8daea Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Mon, 21 Jul 2025 13:28:15 +0000 Subject: [PATCH 5/5] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- executorlib/standalone/inputcheck.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/executorlib/standalone/inputcheck.py b/executorlib/standalone/inputcheck.py index cfaa2479..56f39a5d 100644 --- a/executorlib/standalone/inputcheck.py +++ b/executorlib/standalone/inputcheck.py @@ -195,7 +195,7 @@ def validate_number_of_cores( warn( "max_workers parameter is not set, set default based on CPU count to: max_workers=" + str(max_workers), - stacklevel=2 + stacklevel=2, ) return max_workers