diff --git a/src/promptflow/promptflow/executor/_line_execution_process_pool.py b/src/promptflow/promptflow/executor/_line_execution_process_pool.py index 620c9e865988..3be9c8e24212 100644 --- a/src/promptflow/promptflow/executor/_line_execution_process_pool.py +++ b/src/promptflow/promptflow/executor/_line_execution_process_pool.py @@ -426,7 +426,7 @@ def _log_set_worker_count(self, worker_count, estimated_available_worker_count): f"Set process count to {worker_count} with the environment variable 'PF_WORKER_COUNT'.") if estimated_available_worker_count is not None and estimated_available_worker_count < worker_count: bulk_logger.warning( - f"The current process count({worker_count}) is larger than recommended process count" + f"The current process count ({worker_count}) is larger than recommended process count " f"({estimated_available_worker_count}) that estimated by system available memory. This may " f"cause memory exhaustion") diff --git a/src/promptflow/tests/executor/unittests/processpool/test_line_execution_process_pool.py b/src/promptflow/tests/executor/unittests/processpool/test_line_execution_process_pool.py index 185446d1f636..3230b32e7dfa 100644 --- a/src/promptflow/tests/executor/unittests/processpool/test_line_execution_process_pool.py +++ b/src/promptflow/tests/executor/unittests/processpool/test_line_execution_process_pool.py @@ -132,7 +132,7 @@ def test_spawn_mode_parallelism_in_subprocess( f"Set process count to {pf_worker_count} with the environment " f"variable 'PF_WORKER_COUNT'.") mock_logger.warning.assert_any_call( - f"The current process count({pf_worker_count}) is larger than recommended process count" + f"The current process count ({pf_worker_count}) is larger than recommended process count " f"({estimated_available_worker_count}) that estimated by system available memory. This may " f"cause memory exhaustion") elif is_set_environ_pf_worker_count and not is_calculation_smaller_than_set: