This is an automated email from the ASF dual-hosted git repository.
potiuk 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 970f0ef31c3 Fix mypy errors in
`airflow-core/src/airflow/models/taskinstance.py` (#58685)
970f0ef31c3 is described below
commit 970f0ef31c345505cb4506df7e68e320e1f7c332
Author: Vincent <[email protected]>
AuthorDate: Tue Nov 25 19:07:40 2025 -0500
Fix mypy errors in `airflow-core/src/airflow/models/taskinstance.py`
(#58685)
---
airflow-core/src/airflow/models/taskinstance.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/airflow-core/src/airflow/models/taskinstance.py
b/airflow-core/src/airflow/models/taskinstance.py
index d396d9a0f3b..5718efae693 100644
--- a/airflow-core/src/airflow/models/taskinstance.py
+++ b/airflow-core/src/airflow/models/taskinstance.py
@@ -438,7 +438,9 @@ class TaskInstance(Base, LoggingMixin):
# The method to call next, and any extra arguments to pass to it.
# Usually used when resuming from DEFERRED.
next_method: Mapped[str | None] = mapped_column(String(1000),
nullable=True)
- next_kwargs: Mapped[dict | None] =
mapped_column(MutableDict.as_mutable(ExtendedJSON), nullable=True)
+ next_kwargs: Mapped[dict | str | None] = mapped_column(
+ MutableDict.as_mutable(ExtendedJSON), nullable=True
+ )
_task_display_property_value: Mapped[str | None] = mapped_column(
"task_display_name", String(2000), nullable=True
