diff --git a/gcp_airflow_foundations/source_class/salesforce_source.py b/gcp_airflow_foundations/source_class/salesforce_source.py index c538a482..95c4e808 100644 --- a/gcp_airflow_foundations/source_class/salesforce_source.py +++ b/gcp_airflow_foundations/source_class/salesforce_source.py @@ -99,6 +99,8 @@ def gcs_to_bq(self, gcs_bucket, gcs_object, destination_table, **kwargs): destination_project_dataset_table=destination_table + f"_{ds}", write_disposition="WRITE_TRUNCATE", create_disposition="CREATE_IF_NEEDED", + allow_jagged_rows=True, + allow_quoted_newlines=True, skip_leading_rows=1, ) load_to_bq.execute(context=kwargs)