Module core

distributed.protocol.core

Functions

▶ def dumps(msg, serializers=None, on_error="message", context=None)
Transform Python message to bytestream suitable for communication
source link
Reexports
- Imported in distributed.protocol.
- Imported in distributed.protocol.tests.test_keras.
- Imported in distributed.protocol.tests.test_numpy.
- Imported in distributed.protocol.tests.test_pandas.
- Imported in distributed.protocol.tests.test_protocol.
- Imported in distributed.protocol.tests.test_serialize.
▶ def dumps_msgpack(msg, compression=None)
Dump msg into header and payload, both bytestrings
source link
```
All of the message must be msgpack encodable

See Also:
    loads_msgpack
```
▶ def loads(frames, deserialize=True, deserializers=None)
Transform bytestream back into Python value
source link
Reexports
- Imported in distributed.protocol.
- Imported in distributed.protocol.tests.test_keras.
- Imported in distributed.protocol.tests.test_numpy.
- Imported in distributed.protocol.tests.test_pandas.
- Imported in distributed.protocol.tests.test_protocol.
- Imported in distributed.protocol.tests.test_serialize.
▶ def loads_msgpack(header, payload)
Read msgpack header and payload back to Python object
source link
```
See Also:
    dumps_msgpack
```