TriggerDAGRunOperator

for task_instance in kwargs['dag_run'].get_task_instances():
        if task_instance.current_state() not in [State.SUCCESS, State.SKIPPED] and \
                task_instance.task_id != kwargs['task_instance'].task_id:
            raise Exception("Task {} failed. Failing this DAG run".format(task_instance.task_id))


Revision #2
Created 9 July 2023 15:44:05 by James
Updated 9 July 2023 15:44:38 by James