airflow/airflow-dags
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

f

Browse Source
This commit is contained in:
Выдрин Сергей
2025-09-05 16:06:27 +03:00
parent f4fefd6c5b
commit 3373ffcea8
3 changed files with 23 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
.history/testpostgre_20250905023148.py Normal file
View File

@@ -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")

11
.history/testpostgre_20250905160615.py Normal file
View File

@@ -0,0 +1,11 @@
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")

2
testpostgre.py
View File

@@ -3,7 +3,7 @@ from airflow.operators.dummy import DummyOperator
from datetime import datetime from datetime import datetime
with DAG( with DAG(
dag_id="hello_world", dag_id="hello_world_postgre",
start_date=datetime(2025, 1, 1), start_date=datetime(2025, 1, 1),
schedule_interval="@daily", schedule_interval="@daily",
catchup=False, catchup=False,