wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-06-27 21:08:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix bug in passing large arguments to tasks. (#5325)

Browse Source
This commit is contained in:
Robert Nishihara
2019-07-30 22:28:35 -07:00
committed by Philipp Moritz
parent 991e71dde6
commit 63a6b0e710
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/ray/_raylet.pyx
+2 -2
View File
@@ -96,7 +96,7 @@ def compute_task_id(ObjectID object_id):
return TaskID(object_id.native().TaskId().Binary())
cdef c_bool is_simple_value(value, int *num_elements_contained):
cdef c_bool is_simple_value(value, int64_t *num_elements_contained):
num_elements_contained[0] += 1
if num_elements_contained[0] >= RayConfig.instance().num_elements_limit():
@@ -170,7 +170,7 @@ def check_simple_value(value):
True if the value should be send by value, False otherwise.
"""
cdef int num_elements_contained = 0
cdef int64_t num_elements_contained = 0
return is_simple_value(value, &num_elements_contained)