...........F..............................................            [100%]
=================================== FAILURES ===================================
__ CaptureIntegrationTests.test_parallel_producers_use_existing_bounded_queue __

self = <test_protected_packet_cache.CaptureIntegrationTests testMethod=test_parallel_producers_use_existing_bounded_queue>

    def test_parallel_producers_use_existing_bounded_queue(self):
        with tempfile.TemporaryDirectory() as root:
            c=self.capture(root)
            r=SimpleNamespace(camera_id=3,events=(),snapshot=lambda:{'cameraId':3})
            threads=[threading.Thread(target=lambda:[c.submit(r) for _ in range(100)]) for _ in range(2)]
            for t in threads:t.start()
            for t in threads:t.join()
>           self.assertEqual(c.results.qsize(),128)
E           AssertionError: 200 != 128

tests/test_protected_packet_cache.py:144: AssertionError
=============================== warnings summary ===============================
../../tmp/codex/ltb1021/2026-10-13_multi-roi_r01/venv/lib/python3.12/site-packages/starlette/testclient.py:45
  /tmp/codex/ltb1021/2026-10-13_multi-roi_r01/venv/lib/python3.12/site-packages/starlette/testclient.py:45: DeprecationWarning: The anyio.abc.BlockingPortal alias is deprecated, use anyio.from_thread.BlockingPortal instead.
    _PortalFactoryType = Callable[[], AbstractContextManager[anyio.abc.BlockingPortal]]

-- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
=========================== short test summary info ============================
FAILED tests/test_protected_packet_cache.py::CaptureIntegrationTests::test_parallel_producers_use_existing_bounded_queue
1 failed, 57 passed, 1 deselected, 1 warning, 3 subtests passed in 3.13s