mirror of
https://github.com/wassname/ray.git
synced 2026-07-06 05:16:30 +08:00
Raise gRPC message size limit to 100MB (#7269)
This commit is contained in:
@@ -38,6 +38,22 @@ def test_ignore_http_proxy(shutdown_only):
|
||||
assert ray.get(f.remote()) == 1
|
||||
|
||||
|
||||
# https://github.com/ray-project/ray/issues/7263
|
||||
def test_grpc_message_size(shutdown_only):
|
||||
ray.init(num_cpus=1)
|
||||
|
||||
@ray.remote
|
||||
def bar(*a):
|
||||
return
|
||||
|
||||
# 50KiB, not enough to spill to plasma, but will be inlined.
|
||||
def f():
|
||||
return np.zeros(50000, dtype=np.uint8)
|
||||
|
||||
# Executes a 10MiB task spec
|
||||
ray.get(bar.remote(*[f() for _ in range(200)]))
|
||||
|
||||
|
||||
# https://github.com/ray-project/ray/issues/7287
|
||||
def test_omp_threads_set(shutdown_only):
|
||||
ray.init(num_cpus=1)
|
||||
|
||||
Reference in New Issue
Block a user