Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Tengo un requisito en el que necesito que el dag desencadenado por TriggerDagRunOperator ejecute un backfill y no solo para la misma fecha de ejecución. El operador TriggerDagOperator está configurado de la siguiente manera: trigger1 = TriggerDagRunOperator( task_id = 'trigger1', trigger_dag_id = 'target_dag', conf = {'message': 'Iniciando objetivo 1'}, reset_dag_run . . . Read more
Actualmente tengo un PythonSensor que espera archivos en un servidor ftp. ¿Es posible que este sensor active una tarea en caso de que ocurra un tiempo de espera? Estoy intentando crear el siguiente dag: diagrama de sensor de airflow He revisado BranchPythonOperator pero parece que ya no obtengo los beneficios . . . Read more
Como puedo ver, no hay una Regla de Desencadenamiento que pueda diferenciar entre los estados “fallido” y “fallido de aguas arriba”. Tenemos que comportarnos de manera diferente cuando el padre se ha ejecutado pero ha fallado y cuando no se ha ejecutado en absoluto. Cuando el estado de la tarea . . . Read more