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

libraylib -> lib (#311)

Browse Source
This commit is contained in:
mehrdadn
2016-07-27 23:23:13 -07:00
committed by Robert Nishihara
parent c3695099fc
commit 4c323d4ecf
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/python/ray/worker.py
+1 -1
View File
@@ -339,7 +339,7 @@ class Worker(object):
"""
if ray.lib.is_arrow(self.handle, objref):
## this is the new codepath
buff, segmentid, metadata_offset = ray.libraylib.get_buffer(self.handle, objref)
buff, segmentid, metadata_offset = ray.lib.get_buffer(self.handle, objref)
metadata_size = np.frombuffer(buff, dtype="int64", count=1)[0]
metadata = np.frombuffer(buff, dtype="byte", offset=8, count=metadata_size)
data = np.frombuffer(buff, dtype="byte")[8 + metadata_size:]
test/runtest.py
+3 -3
View File
@@ -137,10 +137,10 @@ class ObjStoreTest(unittest.TestCase):
# Getting a buffer after modifying it before it finishes should return updated buffer
objref = ray.lib.get_objref(w1.handle)
buf = ray.libraylib.allocate_buffer(w1.handle, objref, 100)
buf = ray.lib.allocate_buffer(w1.handle, objref, 100)
buf[0][0] = 1
ray.libraylib.finish_buffer(w1.handle, objref, buf[1], 0)
completedbuffer = ray.libraylib.get_buffer(w1.handle, objref)
ray.lib.finish_buffer(w1.handle, objref, buf[1], 0)
completedbuffer = ray.lib.get_buffer(w1.handle, objref)
self.assertEqual(completedbuffer[0][0], 1)
ray.services.cleanup()