|
|
@ -19,6 +19,7 @@ def _wrap_in_subprocess(error_queue, fn): |
|
|
|
raise |
|
|
|
raise |
|
|
|
return _wrapped |
|
|
|
return _wrapped |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def _run_in_subprocess(test_case): |
|
|
|
def _run_in_subprocess(test_case): |
|
|
|
error_queue = multiprocessing.Queue() |
|
|
|
error_queue = multiprocessing.Queue() |
|
|
|
wrapped_case = _wrap_in_subprocess(error_queue, test_case) |
|
|
|
wrapped_case = _wrap_in_subprocess(error_queue, test_case) |
|
|
@ -29,6 +30,7 @@ def _run_in_subprocess(test_case): |
|
|
|
raise error_queue.get() |
|
|
|
raise error_queue.get() |
|
|
|
assert proc.exitcode == 0, "Process exited with code {}".format(proc.exitcode) |
|
|
|
assert proc.exitcode == 0, "Process exited with code {}".format(proc.exitcode) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def _test_import_protos(): |
|
|
|
def _test_import_protos(): |
|
|
|
from grpc_tools import protoc |
|
|
|
from grpc_tools import protoc |
|
|
|
proto_path = "tools/distrib/python/grpcio_tools/" |
|
|
|
proto_path = "tools/distrib/python/grpcio_tools/" |
|
|
|