Skip to content

Commit 152d9cc

Browse files
committed
fix unmatched serialized result of task group when using airflow command
1 parent 7c1e49a commit 152d9cc

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

airflow-core/src/airflow/models/serialized_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -376,7 +376,7 @@ def _sort_serialized_dag_dict(cls, serialized_dag: Any):
376376
"""Recursively sort json_dict and its nested dictionaries and lists."""
377377
if isinstance(serialized_dag, dict):
378378
return {k: cls._sort_serialized_dag_dict(v) for k, v in sorted(serialized_dag.items())}
379-
if isinstance(serialized_dag, list):
379+
if isinstance(serialized_dag, list) or isinstance(serialized_dag, tuple):
380380
if all(isinstance(i, dict) for i in serialized_dag):
381381
if all(
382382
isinstance(i.get("__var", {}), Iterable) and "task_id" in i.get("__var", {})

0 commit comments

Comments
 (0)