а
This commit is contained in:
@@ -1,9 +0,0 @@
|
|||||||
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)
|
|
||||||
@@ -1,11 +0,0 @@
|
|||||||
from airflow import DAG
|
|
||||||
from airflow.operators.dummy import DummyOperator
|
|
||||||
from datetime import datetime
|
|
||||||
|
|
||||||
with DAG(
|
|
||||||
dag_id="hello_world_postgre",
|
|
||||||
start_date=datetime(2025, 1, 1),
|
|
||||||
schedule_interval="@daily",
|
|
||||||
catchup=False,
|
|
||||||
) as dag:
|
|
||||||
task = DummyOperator(task_id="dummy_task")
|
|
||||||
Reference in New Issue
Block a user