[CI] Fix failing code-format lint (ray-project#38245)

ray-project#37043, ray-project#37874, and ray-project#38228 broke the code-format lint. This PR fixes it.

Signed-off-by: harborn <[email protected]>

dashboard/modules/reporter/reporter_head.py

@@ -39,8 +39,8 @@
 EMOJI_WARNING = "⚠️"
 WARNING_FOR_MULTI_TASK_IN_A_WORKER = (
  "Warning: This task is running in a worker process that is running multiple tasks. "
- "This can happen if you are profiling a task right as it finishes or if you are using "
- "the Async Actor or Threaded Actors pattern. "
+ "This can happen if you are profiling a task right as it finishes or if you are "
+ "using the Async Actor or Threaded Actors pattern. "
  "The information that follows may come from any of these tasks:"
 )
 SVG_STYLE = """<style>
@@ -185,10 +185,11 @@ async def get_worker_details_for_running_task(
  and worker's ID.
 
  Raises:
- ValueError: If the task attempt is not running or the state APi is not initialized.
+ ValueError: If the task attempt is not running or the state APi is not
+ initialized.
  """
  if self._state_api is None:
- raise ValueError(f"The state API is not initialized yet. Please retry.")
+ raise ValueError("The state API is not initialized yet. Please retry.")
  option = ListApiOptions(
  filters=[
  ("task_id", "=", task_id),

python/ray/data/datasource/file_based_datasource.py

@@ -209,7 +209,7 @@ class FileBasedDatasource(Datasource):
  JSONDatasource, CSVDatasource, NumpyDatasource, BinaryDatasource
  """
 
- # If `_WRITE_FILE_PER_ROW` is `True`, this datasource calls `_write_row` and writes 
+ # If `_WRITE_FILE_PER_ROW` is `True`, this datasource calls `_write_row` and writes
  # each row to a file. Otherwise, this datasource calls `_write_block` and writes
  # each block to a file.
  _WRITE_FILE_PER_ROW = False

python/ray/scripts/scripts.py

@@ -160,7 +160,7 @@ def continue_debug_session(live_jobs: Set[str]):
  continue
 
  print("Continuing pdb session in different process...")
- key = b"RAY_PDB_" + active_session[len("RAY_PDB_CONTINUE_"):]
+ key = b"RAY_PDB_" + active_session[len("RAY_PDB_CONTINUE_") :]
  while True:
  data = ray.experimental.internal_kv._internal_kv_get(
  key, namespace=ray_constants.KV_NAMESPACE_PDB
@@ -1133,9 +1133,7 @@ def on_terminate(proc):
  buckets = [[processes_to_kill[0]], processes_to_kill[1:-1], [processes_to_kill[-1]]]
 
  for bucket in buckets:
- found, stopped, alive = kill_procs(
- force, grace_period / len(buckets), bucket
- )
+ found, stopped, alive = kill_procs(force, grace_period / len(buckets), bucket)
  total_procs_found += found
  total_procs_stopped += stopped
  procs_not_gracefully_killed.extend(alive)