File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed
sdk/python/feast/infra/offline_stores/contrib/ray_offline_store Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -1963,11 +1963,15 @@ def normalize_timestamps(batch: pd.DataFrame) -> pd.DataFrame:
19631963 absolute_path , destination .s3_endpoint_override
19641964 )
19651965 if absolute_path .startswith (REMOTE_STORAGE_SCHEMES ):
1966- write_path = absolute_path .rstrip ('.parquet' ) if absolute_path .endswith ('.parquet' ) else absolute_path
1966+ write_path = (
1967+ absolute_path .rstrip (".parquet" )
1968+ if absolute_path .endswith (".parquet" )
1969+ else absolute_path
1970+ )
19671971 else :
19681972 path_obj = Path (resolved_path )
1969- if path_obj .suffix == ' .parquet' :
1970- path_obj = path_obj .with_suffix ('' )
1973+ if path_obj .suffix == " .parquet" :
1974+ path_obj = path_obj .with_suffix ("" )
19711975 path_obj .mkdir (parents = True , exist_ok = True )
19721976 write_path = str (path_obj )
19731977 ds .write_parquet (write_path )
You can’t perform that action at this time.
0 commit comments