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

01k6f98y6pqgdxm7baky7anbdy.py committed by groupuser

Browse Source
This commit is contained in:
airflow 2025-10-21 06:19:07 +00:00
parent f5bfeb590f
commit 4390d582c1
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dags/groupuser/01k6f98y6pqgdxm7baky7anbdy.py
View File

@ -39,7 +39,7 @@ def write_and_push(**context):
task_id="inline_push",
source_path=TMP_PATH,
dataset_path="outputs/test_output.txt",
repo_url="git@git.dev2.aifrica.co.kr:groupuser/dp-cj.git",
repo_url="https://git.dev2.aifrica.co.kr/groupuser/dp-cj.git",
branch="main",
username="groupuser",
email="groupuser@aifrica.co.kr",
@ -63,8 +63,6 @@ with DAG(
# 기본 4개 태스크
t1 = PythonOperator(task_id="task1", python_callable=log_task, op_kwargs={"task_name": "Task 1"})
t2 = PythonOperator(task_id="task2", python_callable=log_task, op_kwargs={"task_name": "Task 2"})
t3 = PythonOperator(task_id="task3", python_callable=log_task, op_kwargs={"task_name": "Task 3"})
t4 = PythonOperator(task_id="task4", python_callable=log_task, op_kwargs={"task_name": "Task 4"})
# 로그 집계
aggregate = PythonOperator(task_id="aggregate_logs", python_callable=aggregate_logs)
@ -73,4 +71,4 @@ with DAG(
write_and_push_task = PythonOperator(task_id="write_and_push", python_callable=write_and_push)
# 실행 순서
t1 >> t2 >> t3 >> t4 >> aggregate >> write_and_push_task
t1 >> t2 >> aggregate >> write_and_push_task