File tree Expand file tree Collapse file tree 1 file changed +13
-0
lines changed Expand file tree Collapse file tree 1 file changed +13
-0
lines changed Original file line number Diff line number Diff line change @@ -922,6 +922,19 @@ def _to_proto_impl(self) -> DataSourceProto:
922
922
owner = self .owner ,
923
923
)
924
924
925
+ # Only set timestamp fields if we have a batch source and this PushSource doesn't have its own fields
926
+ if self .batch_source and not (
927
+ self .timestamp_field or self .created_timestamp_column or self .field_mapping
928
+ ):
929
+ data_source_proto .timestamp_field = self .batch_source .timestamp_field
930
+ data_source_proto .created_timestamp_column = (
931
+ self .batch_source .created_timestamp_column
932
+ )
933
+ data_source_proto .field_mapping .update (self .batch_source .field_mapping )
934
+ data_source_proto .date_partition_column = (
935
+ self .batch_source .date_partition_column
936
+ )
937
+
925
938
if self .batch_source :
926
939
data_source_proto .batch_source .MergeFrom (self .batch_source .to_proto ())
927
940
You can’t perform that action at this time.
0 commit comments