Commit 060137c7 authored by 김진영's avatar 김진영
Browse files

Update batch_test.py

parent f5827ad4
......@@ -3,8 +3,8 @@ from textwrap import dedent
import pendulum
from airflow.operators.bash import BashOperator
from airflow import DAG
from data.gasan_data import gasanData # import cj-gasan data
from airflow.models import Variable
from data.gasan_data import gasanData # import gasan data
from fail_alert import fail_alert # 실패 시 Teams 알림 발송
# set timezone
......@@ -12,14 +12,14 @@ local_tz = pendulum.timezone("Asia/Seoul")
# set dag
with DAG(
'batch_test',
'bc-gasan',
default_args={
'depends_on_past': False,
'email': 'kim-jy@lotte.net',
#'on_failure_callback': fail_alert
'on_success_callback': fail_alert
},
description='Test Batch Job',
description='dag for gasan batch jobs',
schedule_interval='*/1 * * * *',
start_date=datetime(2022, 5, 13, tzinfo=local_tz),
tags=['test'],
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment