From 85f00880b34fa213b69b81c3b266929790c2e6b1 Mon Sep 17 00:00:00 2001 From: Jarek Potiuk Date: Sun, 6 Aug 2023 15:44:25 +0200 Subject: [PATCH] Give the the test_xcom_ar_map test opportunity to flush the data 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. --- 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 541ab6fcfa928..76d52f4769520 100644 --- a/tests/models/test_xcom_arg_map.py +++ b/tests/models/test_xcom_arg_map.py @@ -253,6 +253,9 @@ def pull(value): for ti in decision.schedulable_tis: ti.run(session=session) + 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: