carloea2 opened a new pull request, #8960: URL: https://github.com/apache/texera/pull/8960
### What changes were proposed in this PR? Keep queue peeking from advancing the round-robin cursor. Scan with a local index so observing a queue does not change the next message returned by get(). ### Any related issues, documentation, discussions? Closes #8225 Replaces #8226, which the stale bot closed. The original PR cannot be reopened by this account. ### How was this PR tested? Tested on freshly fetched main at d27b7b49877bcc52d80602e57f5b0e5f86291736 with Python 3.12 on Windows. The regression failed before the source change and passed after it. From the amber directory, with generated protobuf bindings available on PYTHONPATH: ```text python -m pytest src/test/python/core/util/customized_queue/test_linked_blocking_multi_queue.py::TestPeek::test_priority_group_peek_preserves_round_robin_state -q --tb=line -p no:cacheprovider python -m pytest src/test/python/core/util/customized_queue/test_linked_blocking_multi_queue.py src/test/python/core/models/test_internal_queue.py -q --tb=line -p no:cacheprovider ruff check src/main/python src/test/python ruff format --check src/main/python src/test/python ``` The broader suites passed 76 tests with one expected failure. Ruff lint and formatting passed for all 216 Python files. ### Was this PR authored or co-authored using generative AI tooling? Generated-by: Codex (GPT-6) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
