def METHOD_NAME(
    data_gen_bucket: str,
    benchmark_time: float,
    bulk_read: bool,
    request: pytest.FixtureRequest,
) -> None:
    path_prefix = f"s3://{data_gen_bucket}/parquet/small/partitioned/10000/"
    file_prefix = "input_1"
    paths = [path for path in wr.s3.list_objects(path_prefix) if path[len(path_prefix) :].startswith(file_prefix)]
    with ExecutionTimer(request, data_paths=paths) as timer:
        if bulk_read:
            ray_ds = ray.data.read_parquet_bulk(paths)
        else:
            ray_ds = ray.data.read_parquet(paths)
        frame: pd.DataFrame = ray_ds.to_modin()
    num_files = len(paths)
    assert len(frame) == num_files  # each file contains just one row
    assert timer.elapsed_time < benchmark_time