Update batch_test.py

batch_test.py

@@ -24,6 +24,7 @@ def fail_alert(context):
                     {"name":"■ Task", "value": "%s"},
                     {"name":"■ DAG", "value": "%s"},
                     {"name":"■ Reason", "value": "%s"},
+                    {"name":"■ Log URL", "value": "%s"},
                 ]
             }
         ]
@@ -32,7 +33,8 @@ def fail_alert(context):
         context.get('execution_date')+relativedelta(hours=9), 
         context.get('task_instance').task_id, 
         context.get('task_instance').dag_id,
-        context.get('exception')
+        context.get('exception'),
+        context.get('task_instance').log_url
     )
 
     alert = BashOperator(
@@ -46,7 +48,8 @@ with DAG(
     default_args={
         'depends_on_past': False,
         'email': 'kim-jy@lotte.net',
-        'on_failure_callback': fail_alert
+        #'on_failure_callback': fail_alert
+        'on_success_callback': fail_alert
     },
     description='Test Batch Job',
     schedule_interval='*/1 * * * *',