Skip to content

Commit

Permalink
Rmove bracket
Browse files Browse the repository at this point in the history
  • Loading branch information
Hhhilulu committed Dec 6, 2023
1 parent cc3958a commit f83e559
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -434,7 +434,7 @@ def _calculate_worker_count_with_fork(self):
worker_count = min(self._DEFAULT_WORKER_COUNT, self._nlines)
bulk_logger.info("Using fork to create new process.")
bulk_logger.info(
f"Set process count to ({worker_count}) by taking the minimum value among the "
f"Set process count to {worker_count} by taking the minimum value among the "
f"default worker_count ({self._DEFAULT_WORKER_COUNT}) and the row count ({self._nlines}).")
return worker_count

Expand All @@ -445,7 +445,7 @@ def _calculate_worker_count_without_fork(self, estimated_available_worker_count)
"The environment variable PF_WORKER_COUNT is not set or invalid. Calculate the worker count based "
"on the currently memory usage.")
bulk_logger.info(
f"Set process count to ({worker_count}) by taking the minimum value among estimated process "
f"Set process count to {worker_count} by taking the minimum value among estimated process "
f"count ({estimated_available_worker_count}), the row count ({self._nlines}) and the default "
f"worker count ({self._DEFAULT_WORKER_COUNT}).")
return worker_count
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ def test_fork_mode_parallelism_in_subprocess(
else:
mock_logger.info.assert_any_call("Using fork to create new process.")
mock_logger.info.assert_any_call(
f"Set process count to ({n_process}) by taking the minimum value among the "
f"Set process count to {n_process} by taking the minimum value among the "
f"default worker_count ({pool._DEFAULT_WORKER_COUNT}) and the row count ({nlines})."
)

Expand Down Expand Up @@ -146,7 +146,7 @@ def test_spawn_mode_parallelism_in_subprocess(
"count based on the currently memory usage."
)
mock_logger.info.assert_any_call(
f"Set process count to ({n_process}) by taking the minimum value among estimated "
f"Set process count to {n_process} by taking the minimum value among estimated "
f"process count ({estimated_available_worker_count}), the row count ({nlines}) and the "
f"default worker count ({pool._DEFAULT_WORKER_COUNT})."
)
Expand Down

0 comments on commit f83e559

Please sign in to comment.