This is an automated email from the ASF dual-hosted git repository.
pierrejeambrun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 451b4ad8a4 fix MappedTaskGroup import in taskinstance (#31100)
451b4ad8a4 is described below
commit 451b4ad8a45697947551fde711d997dd4d9cd7cf
Author: JCoder01 <[email protected]>
AuthorDate: Sat May 6 11:57:33 2023 -0400
fix MappedTaskGroup import in taskinstance (#31100)
---
airflow/models/taskinstance.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py
index 5ee6b01f82..43db0ffef8 100644
--- a/airflow/models/taskinstance.py
+++ b/airflow/models/taskinstance.py
@@ -123,6 +123,7 @@ from airflow.utils.sqlalchemy import (
with_row_locks,
)
from airflow.utils.state import DagRunState, State, TaskInstanceState
+from airflow.utils.task_group import MappedTaskGroup
from airflow.utils.timeout import timeout
from airflow.utils.xcom import XCOM_RETURN_KEY
@@ -139,7 +140,7 @@ if TYPE_CHECKING:
from airflow.models.dagrun import DagRun
from airflow.models.dataset import DatasetEvent
from airflow.models.operator import Operator
- from airflow.utils.task_group import MappedTaskGroup, TaskGroup
+ from airflow.utils.task_group import TaskGroup
# This is a workaround because mypy doesn't work with hybrid_property
# TODO: remove this hack and move hybrid_property back to main import block
