We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent dc06cc2 commit 67c41b4Copy full SHA for 67c41b4
sdk/python/feast/data_source.py
@@ -704,7 +704,7 @@ def from_proto(data_source: DataSourceProto):
704
for key, val in schema_pb.items():
705
schema[key] = ValueType(val)
706
707
- assert data_source.push_options.HasField("batch_source")
+ assert data_source.HasField("batch_source")
708
batch_source = DataSource.from_proto(data_source.batch_source)
709
710
return PushSource(
0 commit comments