updated sfv ifelse

franciscojavierarceo · franciscojavierarceo · commit 76064812d226 · 2024-10-02T19:23:27.000-04:00
Signed-off-by: Francisco Javier Arceo &lt;farceo@redhat.com&gt;
diff --git a/sdk/python/feast/feature_store.py b/sdk/python/feast/feature_store.py
@@ -888,8 +888,9 @@ def apply(
         ):
             if isinstance(fv, FeatureView):
                 data_sources_set_to_update.add(fv.batch_source)
-            if fv.stream_source:
-                data_sources_set_to_update.add(fv.stream_source)
+            if hasattr(fv, 'stream_source'):
+                if fv.stream_source:
+                    data_sources_set_to_update.add(fv.stream_source)
             if isinstance(fv, OnDemandFeatureView):
                 for source_fvp in fv.source_feature_view_projections:
                     odfv_batch_source: Optional[DataSource] = (
