diff --git a/.history/user1/testpostgre_20250905021614.py b/.history/user1/testpostgre_20250905021614.py new file mode 100644 index 0000000..07bd8bb --- /dev/null +++ b/.history/user1/testpostgre_20250905021614.py @@ -0,0 +1,7 @@ +from airflow.providers.postgres.operators.postgres import PostgresOperator + +task = PostgresOperator( + task_id='test_query', + postgres_conn_id='my_postgres', + sql='SELECT 1;' +) diff --git a/.history/user1/testpostgre_20250905023149.py b/.history/user1/testpostgre_20250905023149.py new file mode 100644 index 0000000..d748035 --- /dev/null +++ b/.history/user1/testpostgre_20250905023149.py @@ -0,0 +1,11 @@ +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") diff --git a/user1/testpostgre.py b/user1/testpostgre.py index 07bd8bb..d748035 100644 --- a/user1/testpostgre.py +++ b/user1/testpostgre.py @@ -1,7 +1,11 @@ -from airflow.providers.postgres.operators.postgres import PostgresOperator +from airflow import DAG +from airflow.operators.dummy import DummyOperator +from datetime import datetime -task = PostgresOperator( - task_id='test_query', - postgres_conn_id='my_postgres', - sql='SELECT 1;' -) +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")