Specify columns schema for source_table in bigquery merge example

pankajkoti · pankajkoti · commit da7b0d33342a · 2022-11-29T13:45:44.000+05:30
diff --git a/python-sdk/example_dags/example_merge.py b/python-sdk/example_dags/example_merge.py
@@ -68,6 +68,10 @@ def my_df_func(input_df: DataFrame):
             conn_id="bigquery",
             metadata=Metadata(schema="second_table_schema"),
         ),
+        columns=[
+            Column(name="id", type_=types.Integer, primary_key=True),
+            Column(name="name", type_=types.String),
+        ],
     )
     # [START merge_col_list_example]
     aql.merge(
