Module pickle 

Deferred pickling support for Monarch.

This module provides utilities for deferring the pickling of objects that contain async values (futures/tasks) that must be resolved before the final pickle can be produced.

Structs

PendingMessage

A message that is pending resolution of async values before it can be sent.

PicklingState

Python-visible wrapper for the result of a pickling operation.

PicklingStateInner

Inner data for a completed pickling operation.

Functions

pickle

Pickle an object with support for pending pickles and tensor engine references.

pickle_to_part

Pickle a Python object and return the serialized data as a Part.

push_pending_pickle

Push a pending pickle to the active pickling state (Rust-only).

reduce_shared

Reduce a PyShared for pickling.

register_python_bindings

Register the pickle Python bindings into the given module.