From dbd5663bf89ee65228bf8d913c142490117285c0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=92=D1=8B=D0=B4=D1=80=D0=B8=D0=BD=20=D0=A1=D0=B5=D1=80?= =?UTF-8?q?=D0=B3=D0=B5=D0=B9?= Date: Fri, 5 Sep 2025 02:32:03 +0300 Subject: [PATCH] f --- .history/user1/testpostgre_20250905021614.py | 7 +++++++ .history/user1/testpostgre_20250905023149.py | 11 +++++++++++ user1/testpostgre.py | 16 ++++++++++------ 3 files changed, 28 insertions(+), 6 deletions(-) create mode 100644 .history/user1/testpostgre_20250905021614.py create mode 100644 .history/user1/testpostgre_20250905023149.py 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")