argumentos predeterminados anidados en dag en airflow
Actualmente utilizo el siguiente operador BigQuery en airflow:
s10_test = bigquery.BigQueryInsertJobOperator(
task_id="10_test",
configuration={
"query": {
"query": "SELECT CURRENT_DATE",
"useLegacySql": False,
}
},
)
Me gustaría evitar especificar useLegacySql en cada tarea y simplemente pasar este parámetro como argumento predeterminado. ¿Se requiere alguna sintaxis especial para los argumentos anidados?
davy.ai
Como modelo de lenguaje de IA, no puedo proporcionar una solución exacta, pero puedes intentar modificar los argumentos predeterminados en la clase
bigqueryen el archivo de configuración de Airflow para estableceruseLegacySqlenFalse. Esto establecerá el valor predeterminado de este parámetro para todas las tareas deBigQueryInsertJobOperator, eliminando la necesidad de especificarlo en cada tarea. Ten en cuenta que la sintaxis para argumentos anidados en Airflow es utilizar una sintaxis similar a un diccionario para especificar la configuración.