Top "Airflow" questions

Apache Airflow is a workflow management platform to programmatically author, schedule, and monitor workflows as directed acyclic graphs (DAGs) of tasks.

How to run bash script file in Airflow

I have a bash script that creates a file (if it does not exist) that I want to run in …

python airflow
How to run Spark code in Airflow?

Hello people of the Earth! I'm using Airflow to schedule and run Spark tasks. All I found by this time …

java python apache-spark directed-acyclic-graphs airflow
Airflow parallelism

the Local Executor spawns new processes while scheduling tasks. Is there a limit to the number of processes it creates. …

airflow
Airflow backfill clarification

I'm just getting started with Airbnb's airflow, and I'm still not clear on how/when backfilling is done. Specifically, there …

airflow
Can't import Airflow plugins

Following Airflow tutorial here. Problem: The webserver returns the following error Broken DAG: [/usr/local/airflow/dags/test_operator.py] …

airflow
Airflow: How to SSH and run BashOperator from a different server

Is there a way to ssh to different server and run BashOperator using Airbnb's Airflow? I am trying to run …

python ssh airflow
setting up s3 for logs in airflow

I am using docker-compose to set up a scalable airflow cluster. I based my approach off of this Dockerfile https://…

python amazon-s3 airflow
Airbnb Airflow vs Apache Nifi

Are Airflow and Nifi perform the same job on workflows? What are the pro/con for each one? I need …

python apache-nifi airflow
How to remove default example dags in airflow

I am a new user of Airbnb's open source workflow/datapipeline software airflow. There are dozens of default example dags …

python airflow
For Apache Airflow, How can I pass the parameters when manually trigger DAG via CLI?

I use Airflow to manage ETL tasks execution and schedule. A DAG has been created and it works fine. But …

airflow