Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy tratando de programar una tarea de flujo de aire DAG. Programé según el siguiente código: Task1 >> [Task2, Task3] >> Task4 Luego, esperaba que se ejecutara Task4 una sola vez, cuando Task2 y Task3 hubieran terminado. Pero… creo que Task4 se ejecutó dos veces. (task1 -> task2 -> task4) . . . Read more
Me gustaría expresar lo siguiente: “La inserción de un registro con un valor ‘padre’ que no está incluido en ‘rowid’ DESPUÉS DE LA INSERCIÓN está prohibida”. Mi intención es mantener la consistencia interna de la tabla como un grafo dirigido acíclico, donde cada registro es un nodo que se refiere . . . Read more
Estoy usando una máquina Windows y he creado un contenedor para Airflow. Puedo leer datos en el sistema de archivos local a través del DAG, pero no puedo escribir datos en un archivo. También he intentado proporcionar una ruta completa e intentado con diferentes operadores: Python y Bash, pero aún . . . Read more
Recientemente construí 120 dags utilizando Cloud Composer. Todos funcionaron por un tiempo. Todos eran aproximadamente iguales. Cada uno usaba un operador de Python. Cada uno hacía llamadas API a Google Search Console. Cada uno recogía de 7 a 9 mil filas de datos de GSC en un dataframe de Pandas . . . Read more