fix error message

Eventual-Inc · Nov 7, 2024 · 4fea9d7 · 4fea9d7
1 parent f8a22c9
commit 4fea9d7
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/daft/sql/sql_scan.py b/daft/sql/sql_scan.py
@@ -202,12 +202,10 @@ def _get_partition_bounds(self, num_scan_tasks: int) -> list[Any]:
                 pa_table = self.conn.execute_sql_query(percentile_sql)
 
                 if pa_table.num_rows != 1:
-                    raise RuntimeError(f"Failed to get partition bounds: expected 1 row, but got {pa_table.num_rows}.")
+                    raise RuntimeError(f"Expected 1 row, but got {pa_table.num_rows}.")
 
                 if pa_table.num_columns != num_scan_tasks + 1:
-                    raise RuntimeError(
-                        f"Failed to get partition bounds: expected {num_scan_tasks + 1} percentiles, but got {pa_table.num_columns}."
-                    )
+                    raise RuntimeError(f"Expected {num_scan_tasks + 1} percentiles, but got {pa_table.num_columns}.")
 
                 pydict = Table.from_arrow(pa_table).to_pydict()
                 assert pydict.keys() == {f"bound_{i}" for i in range(num_scan_tasks + 1)}