Skip to content

Commit

Permalink
Give the the test_xcom_ar_map test opportunity to flush the data (#33153
Browse files Browse the repository at this point in the history
)

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.
  • Loading branch information
potiuk authored Aug 6, 2023
1 parent 6b892bf commit 6b21b79
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions tests/models/test_xcom_arg_map.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 6b21b79

Please sign in to comment.