Method bad_worker

tests/test_concurrency.py:324–330

()

                    errors.append(exc)

        def bad_worker():
            barrier.wait()
            for _ in range(5):
                try:
                    results.append(isolated_engine.submit_request(dict(bad)))
                except Exception as exc:
                    errors.append(exc)

        threads = (
            [threading.Thread(target=good_worker) for _ in range(2)]