Resultados de la búsqueda a petición "apache-airflow"
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, ...
Las tareas agregadas al DAG durante el tiempo de ejecución no se pueden programar
Mi idea es tener una tareafoo que genera una lista de entradas (usuarios, informes, archivos de registro, etc.) y se inicia una tarea para cada elemento de la lista de entradas. El objetivo es utilizar el reintento de Airflow y otra lógica, en ...
Cómo reiniciar una tarea fallida en Airflow
Estoy usando unFiscal localy mi dag tiene3 tareasdonde la tarea (C) depende de la tarea (A). La tarea (B) y la tarea (A) pueden ejecutarse en paralelo, algo como a continuación A -> C B Entonces la tarea (A) ha falladoy perola tarea (B) ...
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
¿Cómo uso la opción --conf en el flujo de aire?
Estoy tratando de ejecutar un DAG de flujo de aire y necesito pasar algunos parámetros para las tareas. ¿Cómo leo la cadena JSON pasada como parámetro --conf en la línea de comandotrigger_dag comando, en el archivo DAG de python. ex:airflow ...
Flujo de aire: el archivo de registro no es local, ubicación de registro remoto no compatible
No puedo ver los registros adjuntos a las tareas desde la interfaz de usuario de Airflow: [/imgs/8VLEc.png] Las configuraciones relacionadas con el registro en el archivo airflow.cfg son: remote_base_log_folder =base_log_folder ...
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 * * ...
Mensaje flojo fallido del flujo de aire
¿Cómo puedo configurar Airflow para que cualquier falla en el DAG resulte (inmediatamente) en un mensaje flojo? En este momento lo manejo creando una slack_failed_task: slack_failed_task = SlackAPIPostOperator( ...
Flujo de aire: ¿Cómo impulsar el valor de xcom desde PostgreOperator?
Estoy usando Airflow 1.8.1 y quiero enviar el resultado de una solicitud sql de PostgreOperator. Aquí están mis tareas: check_task = PostgresOperator( task_id='check_task', postgres_conn_id='conx', sql="check_task.sql", xcom_push=True, dag=dag) ...
¿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 ...
Página 1 de 2