Commit 8c62802f authored by 김진영's avatar 김진영
Browse files

Update batch_test.py

parent ec3dc330
...@@ -22,7 +22,6 @@ def fail_alert(context): ...@@ -22,7 +22,6 @@ def fail_alert(context):
{"name":"■ Execution Time", "value": "{exec_date}"}, {"name":"■ Execution Time", "value": "{exec_date}"},
{"name":"■ Task", "value": "{task}"}, {"name":"■ Task", "value": "{task}"},
{"name":"■ DAG", "value": "{dag}"}, {"name":"■ DAG", "value": "{dag}"},
{"name":"■ Log URL", "value": "{log_url}"},
] ]
} }
] ]
...@@ -31,7 +30,6 @@ def fail_alert(context): ...@@ -31,7 +30,6 @@ def fail_alert(context):
exec_date=context.get('execution_date'), exec_date=context.get('execution_date'),
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,
) )
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