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:05:35 +03:00
parent f8afe78618
commit f4fefd6c5b
3 changed files with 19 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
.history/testfolder/testhello_20250904110130.py Normal file
View File

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

9
.history/testfolder/testhello_20250905160425.py Normal file
View File

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

2
testfolder/testhello.py
View File

@@ -5,5 +5,5 @@ from datetime import datetime
def hello(): def hello():
print("Hello Airflow!") print("Hello Airflow!")
with DAG("hello_world", start_date=datetime(2025, 9, 4), schedule_interval="@once") as dag: with DAG("hello_world_folder", start_date=datetime(2025, 9, 4), schedule_interval="@once") as dag:
t1 = PythonOperator(task_id="hello", python_callable=hello) t1 = PythonOperator(task_id="hello", python_callable=hello)