(obj)
| 251 | |
| 252 | |
| 253 | def msgpack_serialize(obj): |
| 254 | ctx = ray._private.worker.global_worker.get_serialization_context() |
| 255 | buffer = ctx.serialize(obj) |
| 256 | serialized = buffer.to_bytes() |
| 257 | return serialized |
| 258 | |
| 259 | |
| 260 | def msgpack_deserialize(data): |
searching dependent graphs…