Skip to content

Commit 698bd1a

Browse files
committed
Apply formatting
Signed-off-by: Jonas Bauer <jbauer@easy2parts.com>
1 parent 2134594 commit 698bd1a

File tree

1 file changed

+7
-3
lines changed
  • sdk/python/feast/infra/offline_stores/contrib/ray_offline_store

1 file changed

+7
-3
lines changed

sdk/python/feast/infra/offline_stores/contrib/ray_offline_store/ray.py

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff 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)

0 commit comments

Comments
 (0)