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 <[email protected]>
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
