This is an automated email from the ASF dual-hosted git repository. ephraimanierobi pushed a commit to branch v2-7-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 489d3dd6e91b1320d072a8a919890db3241e1756 Author: Jarek Potiuk <[email protected]> AuthorDate: Sun Aug 6 16:12:56 2023 +0200 Give the the test_xcom_ar_map test opportunity to flush the data (#33153) Using same session in different steps of the same test has the potential of not flishing/committing the changes between. Seems that the #33150 traded one flakiness with another. Attempting to make sure that the flash/commit is executed before the second run. Error: The test RuntimeError: number of values in row (0) differ from number of column processors (29) The error is strange however and indicates a bug in sqlite library. (cherry picked from commit 6b21b79f33e245ff1612b1970d05ef692c41f15c) --- tests/models/test_xcom_arg_map.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/tests/models/test_xcom_arg_map.py b/tests/models/test_xcom_arg_map.py index 05775da574..6dcdc4d60c 100644 --- a/tests/models/test_xcom_arg_map.py +++ b/tests/models/test_xcom_arg_map.py @@ -253,6 +253,9 @@ def test_xcom_map_nest(dag_maker, session): for ti in decision.schedulable_tis: ti.run() + session.flush() + session.commit() + # Now "pull" should apply the mapping functions in order. decision = dr.task_instance_scheduling_decisions(session=session) for ti in decision.schedulable_tis:
