def _run_task(test_template: Callable, tasks_queue: Queue, events_queue: Queue, schema: BaseSchema, checks: Iterable[Callable], settings: hypothesis.settings, seed: Optional[int], results: TestResultSet, **kwargs: Any) -> None:
    with capture_hypothesis_output():
        while (not tasks_queue.empty()):
            endpoint = tasks_queue.get()
            test = make_test_or_exception(endpoint, test_template, settings, seed)
            for event in run_test(schema, endpoint, test, checks, results, **kwargs):
                events_queue.put(event)
def _run_task(test_template: Callable, tasks_queue: Queue, events_queue: Queue, schema: BaseSchema, checks: Iterable[Callable], settings: hypothesis.settings, seed: Optional[int], results: TestResultSet, **kwargs: Any) -> None:
    with capture_hypothesis_output():
        while (not tasks_queue.empty()):
            endpoint = tasks_queue.get()
            test = make_test_or_exception(endpoint, test_template, settings, seed)
            for event in run_test(schema, endpoint, test, checks, results, **kwargs):
                events_queue.put(event)