ti_fails = (
            session
                .query(TF)
                .filter(
                TF.dag_id == dag.dag_id,