This is an automated email from the ASF dual-hosted git repository.
vincbeck 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 0117e77b108 Fix mypy type errors in test_taskinstance.py (#57942)
0117e77b108 is described below
commit 0117e77b108f7d136130021067b903e8d1b06ea5
Author: Yang Yule <[email protected]>
AuthorDate: Fri Nov 7 20:49:13 2025 +0800
Fix mypy type errors in test_taskinstance.py (#57942)
* fix mypy type errors in test_taskinstance.py
* Use tuple
---
airflow-core/tests/unit/models/test_taskinstance.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow-core/tests/unit/models/test_taskinstance.py
b/airflow-core/tests/unit/models/test_taskinstance.py
index c1c98521e17..d651942a0d8 100644
--- a/airflow-core/tests/unit/models/test_taskinstance.py
+++ b/airflow-core/tests/unit/models/test_taskinstance.py
@@ -1685,7 +1685,7 @@ class TestTaskInstance:
for ti in dr.get_task_instances(session=session):
ti.run(session=session)
- events = dict(iter(session.execute(select(AssetEvent.source_task_id,
AssetEvent))))
+ events = dict((tuple(row)) for row in
session.execute(select(AssetEvent.source_task_id, AssetEvent)))
assert set(events) == {"write1", "write2"}
assert events["write1"].source_dag_id == dr.dag_id