Skip to content

Commit 66dcf65

Browse files
committed
Minor lint changes
Signed-off-by: Aniket Paluskar <apaluska@redhat.com>
1 parent 2702254 commit 66dcf65

File tree

1 file changed

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

1 file changed

+1
-3
lines changed

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

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1237,9 +1237,7 @@ def _filter_range(batch: pd.DataFrame) -> pd.Series:
12371237
return _filter_range
12381238

12391239

1240-
def _make_select_distinct_entity_timestamps(
1241-
join_keys: List[str], timestamp_field: str
1242-
):
1240+
def _make_select_distinct_entity_timestamps(join_keys: List[str], timestamp_field: str):
12431241
# Why: factory function for distinct (entity_keys, event_timestamp) projection in Ray map_batches
12441242
# This preserves multiple transactions per entity ID with different timestamps for proper PIT joins
12451243
def _select_distinct_entity_timestamps(batch: pd.DataFrame) -> pd.DataFrame:

0 commit comments

Comments
 (0)