wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-04 08:28:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

[Hotfix] Fix flake8 lint failing (#7118)

Browse Source
This commit is contained in:
Simon Mo
2020-02-10 19:57:21 -08:00
committed by GitHub
parent 4139e02f01
commit bec92a8946
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ci/long_running_tests/workloads/serve.py
+3 -3
View File
@@ -32,16 +32,16 @@ subprocess.call([
"chmod +x hey_linux_amd64"
])
ray.init(address=cluster.address, include_webui=True, webui_host='0.0.0.0')
ray.init(address=cluster.address, include_webui=True, webui_host="0.0.0.0")
serve.init(blocking=True, kv_store_connector=lambda ns: RayInternalKVStore(ns))
@serve.route('/echo')
@serve.route("/echo")
@serve.accept_batch
def echo(_):
time.sleep(0.01) # Sleep for 10ms
ray.show_in_webui(str(serve.context.batch_size), key="Current batch size")
return ['hi {}'.format(i) for i in range(serve.context.batch_size)]
return ["hi {}".format(i) for i in range(serve.context.batch_size)]
print("Scaling to 30 replicas")