This is an automated email from the ASF dual-hosted git repository. kaxilnaik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/master by this push: new 330cd42 Fix bug when marking tasks when DAG Serialization is enabled (#11803) 330cd42 is described below commit 330cd427e1458e92dfe74bd4aefda2392c041282 Author: Kaxil Naik <kaxiln...@gmail.com> AuthorDate: Sat Oct 24 16:01:54 2020 +0100 Fix bug when marking tasks when DAG Serialization is enabled (#11803) This is because `current_task` is of SerializedBaseOperator type. --- airflow/api/common/experimental/mark_tasks.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/api/common/experimental/mark_tasks.py b/airflow/api/common/experimental/mark_tasks.py index 0168285..6534248 100644 --- a/airflow/api/common/experimental/mark_tasks.py +++ b/airflow/api/common/experimental/mark_tasks.py @@ -181,7 +181,7 @@ def get_subdag_runs(dag, session, state, task_ids, commit, confirmed_dates): continue current_task = current_dag.get_task(task_id) - if isinstance(current_task, SubDagOperator): + if isinstance(current_task, SubDagOperator) or current_task.task_type == "SubDagOperator": # this works as a kind of integrity check # it creates missing dag runs for subdag operators, # maybe this should be moved to dagrun.verify_integrity