апгрейду airflow upgrade_check
получаю такой фидбек DAG file /home/airflow/gcs/dags/dag.py with task_id sensor_check_table_exists has unrecognized positional args ()`and keyword args `{'deferrable': True}
сенсор выглядит так
sensor_check_table_exists = BigQueryTableExistenceSensor(
task_id=f"sensor_check_table_exists",
project_id=BQ_PROJECT,
dataset_id=f"ds_id",
table_id=model,
deferrable=True,
timeout=60,
poke_interval=10,
retries=0,
)
юзаю следующую версию `apache-airflow-backport-providers-google==2021.3.3`
нашел в их коде https://github.com/apache/airflow/blob/main/airflow/providers/google/cloud/sensors/bigquery.py#L75 что это определяется конфигом
но я пока не пойму для как это задать и как это должно выглядеть для моей версии.
гугл ничего вразумительного не дает
как это правильно править, подскажите, пожалуйста?)
@ruairflow
Обсуждают сегодня