"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.
Post a Comment for ""invalid Arguments Passed" Error For Dag That Loads Mysql Data To Bigquery Using Airflow"