sla_miss_callback
Opened this issue · 1 comments
deepakjindal90 commented
sla_miss_callback functionality should be like below
if utils.check_dict_key(
dag_params, "on_success_callback_name"
) and utils.check_dict_key(dag_params, "on_success_callback_file"):
dag_params["on_success_callback"]: Callable = utils.get_python_callable(
dag_params["on_success_callback_name"],
dag_params["on_success_callback_file"],
)
dag_params["default_args"]["on_success_callback"]: Callable = utils.get_python_callable(
dag_params["on_success_callback_name"],
dag_params["on_success_callback_file"],
)
zohairshaikh commented
Try passing sla_miss_callback
on the dag level, this seems to be working in my case
"dag_id":
sla_miss_callback: module.file.func_name
default_args:
owner: 'airflow'
...