Resultados de la búsqueda a petición "apache-airflow"

3 la respuesta

Haga macros de Airflow personalizadas para expandir otras macros

¿Hay alguna manera de hacer una macro definida por el usuario en Airflow que se calcule a partir de otras macros? from airflow import DAG from airflow.operators.bash_operator import BashOperator dag = DAG( 'simple', schedule_interval='0 21 * * ...

2 la respuesta

¿Cómo iterar dinámicamente sobre la salida de una tarea aguas arriba para crear tareas paralelas en el flujo de aire?

Considere el siguiente ejemplo de un DAG donde la primera tarea,get_id_creds, extrae una lista de credenciales de una base de datos. Esta operación me dice en qué usuarios de mi base de datos puedo ejecutar más procesamiento previo de datos y ...

4 la respuesta

Las configuraciones de autenticación de flujo de aire fallan con "AttributeError: no se puede establecer el atributo"

La configuración de autenticación de contraseña de Airflow versión 1.8 como se describe endocs [https://airflow.apache.org/security.html]falla en el paso user.password = 'set_the_password'con error AttributeError: can't set attribute

2 la respuesta

zona horaria predeterminada de apache-airflow 1.9 establecida en no utc

Recientemente actualicé la versión Airflow de Airflow 1.8 a Apache-Airflow 1.9, la actualización fue exitosa y escalé el entorno usando Celery Executor, todo parecía funcionar bien, pero las fechas de inicio de dag y tareas, fechas de ejecución, ...