f
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", start_date=datetime(2025, 9, 4), schedule_interval="@once") as dag:
|
|
||||||
t1 = PythonOperator(task_id="hello", python_callable=hello)
|
|
||||||
@@ -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",
|
|
||||||
start_date=datetime(2025, 1, 1),
|
|
||||||
schedule_interval="@daily",
|
|
||||||
catchup=False,
|
|
||||||
) as dag:
|
|
||||||
task = DummyOperator(task_id="dummy_task")
|
|
||||||
@@ -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")
|
|
||||||
@@ -1,7 +0,0 @@
|
|||||||
from airflow.providers.postgres.operators.postgres import PostgresOperator
|
|
||||||
|
|
||||||
task = PostgresOperator(
|
|
||||||
task_id='test_query',
|
|
||||||
postgres_conn_id='my_postgres',
|
|
||||||
sql='SELECT 1;'
|
|
||||||
)
|
|
||||||
@@ -1,11 +0,0 @@
|
|||||||
from airflow import DAG
|
|
||||||
from airflow.operators.dummy import DummyOperator
|
|
||||||
from datetime import datetime
|
|
||||||
|
|
||||||
with DAG(
|
|
||||||
dag_id="hello_world",
|
|
||||||
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