Delete dags/groupuser/01kasq8kfqqwr0s52dayhs71vc.py

This commit is contained in:
cheetahadmin 2026-03-05 00:04:56 +00:00
parent dea7da3efa
commit c4c27667f1

@ -1,75 +0,0 @@
# ----------------------------------------------
# Cheetah Pipeline Template
# ----------------------------------------------
# USER_EDIT_IMPORT_START
# 필요한 라이브러리 import 영역
# 예)
from airflow.operators.bash import BashOperator
from airflow.operators.python import PythonOperator
import time
# USER_EDIT_IMPORT_END
from decorators.cheetah_pipeline_decorator import cheetah_pipeline
from airflow import DAG
from datetime import datetime
@cheetah_pipeline(
upload_outputs=True,
push_to_dataset=True,
s3_bucket=None,
s3_conn_id=None
)
def dag_template():
# ------------------------------------------------
# DAG 기본 설정 (수정 가능)
# ------------------------------------------------
# USER_EDIT_DAG_META_START
start_date = datetime(2024, 1, 1)
schedule = None
catchup = False
tags = []
# USER_EDIT_DAG_META_END
with DAG(
dag_id='ca_pip-test',
start_date=start_date,
schedule=schedule,
catchup=catchup,
tags=tags,
is_paused_upon_creation=False
) as dag:
# ------------------------------------------------
# TASK 작성 영역 (수정 가능)
# ------------------------------------------------
# USER_EDIT_TASK_START
def generate_json(**context):
with open("result.json", "w") as f:
f.write('{"model": "v1", "f1": 0.95}')
print("Task2 completed")
t1 = BashOperator(
task_id="task1",
bash_command="""
echo "Loss=0.12, Accuracy=0.98" > metrics.txt
"""
)
t2 = PythonOperator(
task_id="task2",
python_callable=generate_json
)
t1 >> t2
# USER_EDIT_TASK_END
return dag
dag = dag_template()