diff --git a/benchmarking/tpcds/ray_entrypoint.py b/benchmarking/tpcds/ray_entrypoint.py index 34f2511fa7..20656b37b9 100644 --- a/benchmarking/tpcds/ray_entrypoint.py +++ b/benchmarking/tpcds/ray_entrypoint.py @@ -36,7 +36,7 @@ def register_catalog(scale_factor: int) -> SQLCatalog: return SQLCatalog( tables={ table: daft.read_parquet( - f"s3://eventual-dev-benchmarking-fixtures/uncompressed/tpcds-dbgen/{scale_factor}/{table}.parquet/" + f"s3://eventual-dev-benchmarking-fixtures/uncompressed/tpcds-dbgen/{scale_factor}/{table}.parquet" ) for table in TABLE_NAMES }