Problema ¿Hay alguna forma en Airflow de crear un flujo de trabajo tal que se desconozca el número de tareas B. * hasta que se complete la Tarea A? He analizado los subdags, pero parece que solo puede funcionar con un conjunto estático de tareas que deben determinarse en la creación de...
Después de una nueva instalación utilizando pip install apache-airflow, cualquier intento de ejecutar el flujo de aire termina con un error de importación de Python: Traceback (most recent call last): File "/Users/\*/env/bin/airflow", line 26, in <module> from airflow.bin.cli import...
Instalación realizada correctamente. db se inició correctamente e intenta iniciar el servidor web muestra el siguiente error. Reinstalé todo pero todavía no funciona. Apreciaré si alguien me ayuda. Salida de consola: $:~/airflow# airflow webserver -p 8080 ____________ _____________ ____ |__(...
Cerrado. Esta pregunta no es reproducible o fue causada por errores tipográficos . Actualmente no está aceptando respuestas. ¿Quieres mejorar esta pregunta? Actualice la pregunta para que sea sobre el tema de Stack Overflow. Cerrado hace 3 meses .
Estoy usando https://github.com/helm/charts/tree/master/stable/airflow helm chart y construyendo la puckle/docker-airflowimagen v1.10.8 con kubernetes instalados y usando esa imagen en el helm chart, pero sigo obteniendo File "/usr/local/bin/airflow", line 37, in <module> args.func(args)...
Estoy tratando de mover archivos s3 de un depósito "sin eliminación" (lo que significa que no puedo eliminar los archivos) a GCS usando el flujo de aire. No puedo garantizar que haya nuevos archivos todos los días, pero debo buscar nuevos archivos todos los días. Mi problema es la creación...
Tengo un escenario como el siguiente: Gatillo una Task 1y Task 2sólo cuando los nuevos datos es avialable para ellos en la tabla de origen (Athena). El desencadenante para la Tarea1 y la Tarea2 debería ocurrir cuando se realiza una nueva partición de datos en un día. Activar Task 3solo al...