Commit 1ce3e7dd authored by 김진영's avatar 김진영
Browse files

Update batch_test.py

parent ac528f83
......@@ -19,18 +19,14 @@ def fail_alert(context):
"sections": [
{
"facts":[
{"name":"■ Execution Time", "value": "{exec_date}"},
{"name":"■ Task", "value": "{task}"},
{"name":"■ DAG", "value": "{dag}"},
{"name":"■ Execution Time", "value": "%s"},
{"name":"■ Task", "value": "%s"},
{"name":"■ DAG", "value": "%s"},
]
}
]
}
""".format(
exec_date=context.get('execution_date'),
task=context.get('task_instance').task_id,
dag=context.get('task_instance').dag_id,
)
""" % (context.get('execution_date'), context.get('task_instance').task_id, context.get('task_instance').dag_id)
alert = BashOperator(
task_id='fail_alert',
......
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