airflow list_dags
查看DAG列表。airflow test
测试DAG文件。示例代码:
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime
dag = DAG(
'sample_dag',
description='Sample DAG',
schedule_interval='0 0 * * *',
start_date=datetime(2022, 1, 1),
catchup=False
)
task1 = BashOperator(
task_id='task1',
bash_command='echo "Hello, World!"',
dag=dag
)
task2 = BashOperator(
task_id='task2',
bash_command='echo "Goodbye, World!"',
dag=dag
)
task1 >> task2