Skip to content

Commit c5e0da2

Browse files
authored
chore: Support passing list of Entities to a feature view definition (#2528)
Signed-off-by: Achal Shah <achals@gmail.com>
1 parent 82fb277 commit c5e0da2

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

sdk/python/feast/feature_view.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ def __init__(
9797
self,
9898
*args,
9999
name: Optional[str] = None,
100-
entities: Optional[List[str]] = None,
100+
entities: Optional[Union[List[Entity], List[str]]] = None,
101101
ttl: Optional[Union[Duration, timedelta]] = None,
102102
batch_source: Optional[DataSource] = None,
103103
stream_source: Optional[DataSource] = None,
@@ -167,7 +167,11 @@ def __init__(
167167
raise ValueError("feature view name needs to be specified")
168168

169169
self.name = _name
170-
self.entities = _entities if _entities else [DUMMY_ENTITY_NAME]
170+
self.entities = (
171+
[e.name if isinstance(e, Entity) else e for e in _entities]
172+
if _entities
173+
else [DUMMY_ENTITY_NAME]
174+
)
171175

172176
self._initialize_sources(_name, batch_source, stream_source, source)
173177

sdk/python/tests/integration/feature_repos/universal/feature_views.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
)
1919
from feast.data_source import DataSource, RequestSource
2020
from feast.types import FeastType
21+
from tests.integration.feature_repos.universal.entities import location
2122

2223

2324
def driver_feature_view(
@@ -217,7 +218,7 @@ def create_order_feature_view(source, infer_features: bool = False):
217218
def create_location_stats_feature_view(source, infer_features: bool = False):
218219
location_stats_feature_view = FeatureView(
219220
name="location_stats",
220-
entities=["location_id"],
221+
entities=[location()],
221222
schema=None if infer_features else [Field(name="temperature", dtype=Int32)],
222223
source=source,
223224
ttl=timedelta(days=2),

0 commit comments

Comments
 (0)