updated stream feature view piece

franciscojavierarceo · franciscojavierarceo · commit 01770e28b058 · 2024-10-02T18:06:24.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,9 +888,8 @@ def apply(
         ):
             if isinstance(fv, FeatureView):
                 data_sources_set_to_update.add(fv.batch_source)
-            if isinstance(fv, StreamFeatureView):
-                if fv.stream_source:
-                    data_sources_set_to_update.add(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] = (
