Method worker

tests/test_concurrency.py:277–284

()

        barrier = threading.Barrier(6)

        def worker():
            barrier.wait()
            for _ in range(5):
                try:
                    r = isolated_engine.submit_request(dict(bad_payload))
                    results.append(r)
                except Exception as exc:
                    errors.append(exc)

        threads = [threading.Thread(target=worker) for _ in range(6)]
        for t in threads: