[Data] Fix iceberg warning msg (ray-project#60044)

owenowenisme · peterxcli · commit c5ab772a02d9 · 2026-02-25T16:15:54.000+08:00
Fixes missing space in the warning message.

---------

Signed-off-by: You-Cheng Lin &lt;mses010108@gmail.com&gt;
Signed-off-by: peterxcli &lt;peterxcli@gmail.com&gt;
diff --git a/python/ray/data/_internal/datasource/iceberg_datasource.py b/python/ray/data/_internal/datasource/iceberg_datasource.py
@@ -434,8 +434,7 @@ def get_read_tasks(
         if parallelism > len(list(plan_files)):
             parallelism = len(list(plan_files))
             logger.warning(
-                f"Reducing the parallelism to {parallelism}, as that is the"
-                "number of files"
+                f"Reducing the parallelism to {parallelism}, as that is the number of files"
             )
 
         # Get required properties for reading tasks - table IO, table metadata,

Original file line number	Diff line number	Diff line change
`@@ -434,8 +434,7 @@ def get_read_tasks(`
`434`	`434`	`if parallelism > len(list(plan_files)):`
`435`	`435`	`parallelism = len(list(plan_files))`
`436`	`436`	`logger.warning(`
`437`		`- f"Reducing the parallelism to {parallelism}, as that is the"`
`438`		`- "number of files"`
	`437`	`+ f"Reducing the parallelism to {parallelism}, as that is the number of files"`
`439`	`438`	`)`
`440`	`439`
`441`	`440`	`# Get required properties for reading tasks - table IO, table metadata,`