Class CloudWrapper

hyperqueue.task.function.wrapper.CloudWrapper

Wraps a callable so that cloudpickle is used to pickle it, caching the pickle.

Declaration

class CloudWrapper

Documentation

Methods

▷ def __call__(self, *args, **kwargs)
source link
▷ def __init__(self, fn, pickled_fn=None, cache=True, protocol=cloudpickle.DEFAULT_PROTOCOL)
source link
▷ def __reduce__(self)
source link
▷ def __repr__(self)
source link
▷ def is_generator_function(self)
source link

Reexports

Imported in hyperqueue.task.function.