Skip to content

Commit

Permalink
Add space
Browse files Browse the repository at this point in the history
  • Loading branch information
Hhhilulu committed Dec 6, 2023
1 parent c3207e9 commit ac1d0ae
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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")

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit ac1d0ae

Please sign in to comment.