Skip to content Skip to sidebar Skip to footer

"invalid Arguments Passed" Error For Dag That Loads Mysql Data To Bigquery Using Airflow

I running a DAG that extracts MySQL data and loads it to BigQuery in airflow. I am currectly getting the following error: /usr/local/lib/python2.7/dist-packages/airflow/models.py:

Solution 1:

Reading the source here: https://github.com/apache/incubator-airflow/blob/master/airflow/contrib/operators/gcs_to_bq.py

Please remove these parameters from the default arguments:

google_cloud_storage_connn_id = 'podioGCPConnection'project_id = 'podio-data',

You need to create a connection in the Airflow dashboard.

enter image description here

Post a Comment for ""invalid Arguments Passed" Error For Dag That Loads Mysql Data To Bigquery Using Airflow"