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

Reply via email to