diff --git a/python/ray/data/datasource/file_based_datasource.py b/python/ray/data/datasource/file_based_datasource.py index 48f1730c43245..5004d2f840165 100644 --- a/python/ray/data/datasource/file_based_datasource.py +++ b/python/ray/data/datasource/file_based_datasource.py @@ -314,7 +314,6 @@ def write( # if an S3 URI is provided. tmp = _add_creatable_buckets_param_if_s3_uri(path) filesystem.create_dir(tmp, recursive=True) - filesystem = _wrap_s3_serialization_workaround(filesystem) fs = _unwrap_s3_serialization_workaround(filesystem)