Skip to content

Commit 800aa70

Browse files
committed
fix copy polars df
1 parent ee11f1c commit 800aa70

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Diff for: python/hsfs/engine/python.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -1428,7 +1428,7 @@ def _start_offline_materialization(offline_write_options: Dict[str, Any]) -> boo
14281428
return True
14291429

14301430
@staticmethod
1431-
def _convert_feature_log_to_df(feature_log, cols):
1431+
def _convert_feature_log_to_df(feature_log, cols) -> pd.DataFrame:
14321432
if feature_log is None and cols:
14331433
return pd.DataFrame(columns=cols)
14341434
if not (
@@ -1449,7 +1449,7 @@ def _convert_feature_log_to_df(feature_log, cols):
14491449
return pd.DataFrame(feature_log, columns=cols)
14501450
else:
14511451
if isinstance(feature_log, pl.DataFrame):
1452-
return feature_log.clone()
1452+
return feature_log.clone().to_pandas()
14531453
elif isinstance(feature_log, pd.DataFrame):
14541454
return feature_log.copy(deep=False)
14551455

0 commit comments

Comments
 (0)