Skip to content

Commit d910f92

Browse files
committed
_time_travel_format test
1 parent 55bf758 commit d910f92

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

python/hsfs/feature_group.py

+3-3
Original file line numberDiff line numberDiff line change
@@ -2225,7 +2225,7 @@ def __init__(
22252225
features: Optional[List[Union["feature.Feature", Dict[str, Any]]]] = None,
22262226
location: Optional[str] = None,
22272227
online_enabled: bool = False,
2228-
time_travel_format: Optional[str] = "HUDI",
2228+
time_travel_format: Optional[str] = None,
22292229
statistics_config: Optional[Union["StatisticsConfig", Dict[str, Any]]] = None,
22302230
online_topic_name: Optional[str] = None,
22312231
topic_name: Optional[str] = None,
@@ -2333,8 +2333,8 @@ def __init__(
23332333
self._hudi_precombine_key = (
23342334
util.autofix_feature_name(hudi_precombine_key)
23352335
if hudi_precombine_key is not None
2336-
and self._time_travel_format is not None
2337-
and self._time_travel_format == "HUDI"
2336+
and (self._time_travel_format is None
2337+
or self._time_travel_format == "HUDI")
23382338
else None
23392339
)
23402340
self.statistics_config = statistics_config

0 commit comments

Comments
 (0)