Untitled
unknown
plain_text
3 years ago
471 B
12
Indexable
from datetime import datetime
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
def print_hello():
return 'Hello world from first Airflow DAG!'
dag123 = DAG('hello_world', description='Hello World DAG!!',
schedule_interval='0 12 * * *',
start_date=datetime(2023, 4, 26), catchup=False)
hello_operator = PythonOperator(task_id='hello_task', python_callable=print_hello, dag=dag123)
hello_operatorEditor is loading...