astronomer/dag-factory

sla_miss_callback

Opened this issue · 1 comments

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"],
        )

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'
        ...