Skip to content

Remove taskflow code from Airflow intro example #26486

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
BasPH wants to merge 2 commits into from
Closed

Remove taskflow code from Airflow intro example #26486

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
85f4616
Don't mix classic and taskflow style operators to reduce complexity
BasPH Sep 19, 2022
443d6de
Remove 'as dag' now that it's unnecessary
BasPH Sep 19, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 5 additions & 8 deletions docs/apache-airflow/index.rst
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -40,27 +40,24 @@ Take a look at the following snippet of code:
from datetime import datetime

from airflow import DAG
from airflow.decorators import task
from airflow.operators.bash import BashOperator
from airflow.operators.python import PythonOperator

# A DAG represents a workflow, a collection of tasks
with DAG(dag_id="demo", start_date=datetime(2022, 1, 1), schedule="0 0 * * *") as dag:
with DAG(dag_id="demo", start_date=datetime(2022, 1, 1), schedule="0 0 * * *"):

# Tasks are represented as operators
hello = BashOperator(task_id="hello", bash_command="echo hello")

@task()
def airflow():
print("airflow")
airflow = PythonOperator(task_id="airflow", python_callable=lambda: print("airflow"))

# Set dependencies between tasks
hello >> airflow()
hello >> airflow


Here you see:

- A DAG named "demo", starting on Jan 1st 2022 and running once a day. A DAG is Airflow's representation of a workflow.
- Two tasks, a BashOperator running a Bash script and a Python function defined using the ``@task`` decorator
- Two tasks, a BashOperator running a Bash script and a PythonOperator running a Python script
- ``>>`` between the tasks defines a dependency and controls in which order the tasks will be executed

Airflow evaluates this script and executes the tasks at the set interval and in the defined order. The status
Expand Down