Apache Airflow est une plate-forme de gestion de flux de travail permettant de créer, de planifier et de surveiller par programme des flux de travail sous forme de graphiques acycliques dirigés (DAG) de tâches.
J'ai besoin d'accéder au paramètre passé par BigqueryOperator dans le fichier sql, mais j'obtiens une erreur ERROR - l'argument queryParameters doit avoir un type ...
J'ai un DAG décrit comme ceci: bucket_name
|- airflow.cfg
|- dags
|_ pipeline.py
|- ...
|_ sql_requests
|_ create_table.sql
La tâche create_table a ...
J'ai créé un BranchPythonOperator qui appelle 2 tâches en fonction de la condition comme: class CheckTable:
"""
DAG task to check if table exists or not.
"""
...
