9 lines
311 B
Python
9 lines
311 B
Python
from airflow import DAG
|
|
from airflow.operators.python import PythonOperator
|
|
from datetime import datetime
|
|
|
|
def hello():
|
|
print("Hello Airflow!")
|
|
|
|
with DAG("hello_world_folder", start_date=datetime(2025, 9, 4), schedule_interval="@once") as dag:
|
|
t1 = PythonOperator(task_id="hello", python_callable=hello) |