Commit ec3dc330 authored by 김진영's avatar 김진영
Browse files

Update batch_test.py

parent 89803127
...@@ -23,7 +23,6 @@ def fail_alert(context): ...@@ -23,7 +23,6 @@ def fail_alert(context):
{"name":"■ Task", "value": "{task}"}, {"name":"■ Task", "value": "{task}"},
{"name":"■ DAG", "value": "{dag}"}, {"name":"■ DAG", "value": "{dag}"},
{"name":"■ Log URL", "value": "{log_url}"}, {"name":"■ Log URL", "value": "{log_url}"},
{"name":"■ Reason", "value":"{reason}"}
] ]
} }
] ]
...@@ -33,7 +32,6 @@ def fail_alert(context): ...@@ -33,7 +32,6 @@ def fail_alert(context):
task=context.get('task_instance').task_id, task=context.get('task_instance').task_id,
dag=context.get('task_instance').dag_id, dag=context.get('task_instance').dag_id,
log_url=context.get('task_instance').log_url, log_url=context.get('task_instance').log_url,
reason=context.get('exception')
) )
alert = BashOperator( alert = BashOperator(
......
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