Address comments

Signed-off-by: Cheng Su <scnju13@gmail.com>
ray-project · Jan 29, 2024 · c480cb3 · c480cb3
1 parent f5de03e
commit c480cb3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/python/ray/data/_internal/execution/operators/task_pool_map_operator.py b/python/ray/data/_internal/execution/operators/task_pool_map_operator.py
@@ -42,7 +42,6 @@ def __init__(
                 or None to use as many tasks as possible.
             ray_remote_args: Customize the ray remote args for this op's tasks.
         """
-        self._concurrency = concurrency
         super().__init__(
             map_transformer,
             input_op,
@@ -51,6 +50,7 @@ def __init__(
             min_rows_per_bundle,
             ray_remote_args,
         )
+        self._concurrency = concurrency
 
     def _add_bundled_input(self, bundle: RefBundle):
         # Submit the task as a normal Ray task.

diff --git a/python/ray/data/_internal/util.py b/python/ray/data/_internal/util.py
@@ -601,7 +601,7 @@ def get_compute_strategy(
                     raise ValueError(
                         "``concurrency`` is set as a tuple of integers, but ``fn`` "
                         f"is not a callable class: {fn}. Use ``concurrency=n`` to "
-                        "control maximal number of workers to use."
+                        "control maximum number of workers to use."
                     )
             else:
                 raise ValueError(