diff --git a/sdk/python/feast/feature_view.py b/sdk/python/feast/feature_view.py index a833c7a5e5b..a02023f0c52 100644 --- a/sdk/python/feast/feature_view.py +++ b/sdk/python/feast/feature_view.py @@ -218,7 +218,8 @@ def to_proto(self) -> FeatureViewProto: ttl_duration.FromTimedelta(self.ttl) batch_source_proto = self.batch_source.to_proto() - batch_source_proto.data_source_class_type = f"{self.batch_source.__class__.__module__}.{self.batch_source.__class__.__name__}" + if batch_source_proto is not None: + batch_source_proto.data_source_class_type = f"{self.batch_source.__class__.__module__}.{self.batch_source.__class__.__name__}" stream_source_proto = None if self.stream_source: