Skip to content

Commit 282730e

Browse files
committed
Address test flake
1 parent 7417703 commit 282730e

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

tests/integration/rest_asyncio/db/data/conftest.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -268,9 +268,13 @@ async def poll_until_lsn_reconciled_async(
268268
done = True
269269
logger.debug(f"LSN {target_lsn} is reconciled after {total_time}s")
270270
else:
271-
logger.debug(
272-
f"LSN not yet reconciled. Reconciled: {reconciled_lsn}, target: {target_lsn}"
271+
hard_sleep_seconds = 30
272+
logger.warning(
273+
f"LSN header not found in query response. Available headers: {list(query_raw_headers.keys())}. Falling back to hard-coded sleep for {hard_sleep_seconds} seconds."
273274
)
275+
await asyncio.sleep(hard_sleep_seconds)
276+
done = True
277+
continue
274278
except Exception as e:
275279
logger.debug(f"Error checking LSN: {e}")
276280

0 commit comments

Comments
 (0)