flux.future module

class flux.future.Future(future_handle, prefixes=None, pimpl_t=None)

Bases: flux.wrapper.WrapperPimpl

A wrapper for interfaces that create and consume flux futures

class InnerWrapper(handle=None, match=<sphinx.ext.autodoc.importer._MockObject object>, filter_match=True, prefixes=None, destructor=<bound method ? of <flux.core.inner.Core object>>)

Bases: flux.wrapper.Wrapper

check_wrap(fun, name)
error_string()
get(*args, **kwargs)
get_flux()
get_reactor()
incref()
is_ready()
reset()
then(callback, *args, timeout=-1.0, **kwargs)
wait_for(*args, **kwargs)
class flux.future.WaitAllFuture(children=None)

Bases: flux.future.Future

Create a composite future which waits for all children to be fulfilled

push(child, name=None)
flux.future.continuation_callback(c_future, opaque_handle)