Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fix-lint
Signed-off-by: Vanshika Vanshika <vvanshik@redhat.com>

rh-pre-commit.version: 2.3.2
rh-pre-commit.check-secrets: ENABLED
  • Loading branch information
Vperiodt committed Apr 17, 2026
commit 14d79e8fdde79f0ba2264c1965478571d7f50769
8 changes: 3 additions & 5 deletions sdk/python/feast/infra/offline_stores/duckdb.py
Original file line number Diff line number Diff line change
Expand Up @@ -124,11 +124,7 @@ def _build_entity_df_from_sources(
end_date: datetime,
data_source_reader: Callable[[DataSource, str], Table],
) -> pd.DataFrame:
"""Derive an entity DataFrame from feature view sources for non-entity retrieval.

Reads distinct join keys from each feature view source within the time window,
unions them, and adds event_timestamp = end_date for point-in-time joins.
"""
entity_dfs: List[pd.DataFrame] = []

for fv in feature_views:
Expand Down Expand Up @@ -157,7 +153,9 @@ def _build_entity_df_from_sources(
entity_dfs.append(distinct_entities)

if not entity_dfs:
return pd.DataFrame({DEFAULT_ENTITY_DF_EVENT_TIMESTAMP_COL: [end_date]})
return pd.DataFrame(
{DEFAULT_ENTITY_DF_EVENT_TIMESTAMP_COL: [end_date]}
)

combined = pd.concat(entity_dfs, ignore_index=True)

Expand Down