(ray_start_regular)
| 290 | |
| 291 | |
| 292 | def test_numpy_serialization(ray_start_regular): |
| 293 | array = np.zeros(314) |
| 294 | from ray.cloudpickle import dumps |
| 295 | |
| 296 | buffers = [] |
| 297 | inband = dumps(array, protocol=5, buffer_callback=buffers.append) |
| 298 | assert len(inband) < array.nbytes |
| 299 | assert len(buffers) == 1 |
| 300 | |
| 301 | |
| 302 | def test_numpy_subclass_serialization_pickle(ray_start_regular): |
nothing calls this directly
no test coverage detected
searching dependent graphs…