Module Import alias Import alias ImportFrom alias Import alias Import alias Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias Import alias ImportFrom alias identifier ImportFrom alias ImportFrom alias identifier ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore Str Assign NameStore Str Assign NameStore ListLoad AttributeLoad NameLoad attr NameLoad TryExcept body Import alias identifier Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Pass Assign NameStore Call NameLoad NameLoad Assign NameStore TupleLoad NameLoad NameLoad Assign NameStore AttributeLoad NameLoad attr Assign NameStore Str Assign NameStore Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad FunctionDef arguments args NameParam NameParam defaults body TryExcept body Assign NameStore Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Return TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body TryExcept body Assign NameStore Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Return TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body With Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad keyword NameLoad body TryFinally body TryExcept body Expr Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type NameLoad body Assign NameStore Call AttributeLoad NameLoad attr finalbody Expr Call AttributeLoad NameLoad attr Return TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index AttributeLoad NameLoad attr NameLoad Assign SubscriptStore NameLoad Index AttributeLoad NameLoad attr NameLoad With Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad keyword NameLoad body TryFinally body TryExcept body Expr Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type NameLoad body Assign NameStore Call AttributeLoad NameLoad attr finalbody Expr Call AttributeLoad NameLoad attr Return TupleLoad NameLoad NameLoad decorator_list ClassDef bases AttributeLoad NameLoad attr body Expr Str FunctionDef arguments args NameParam defaults body Return CompareEq AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Return CompareEq AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body If CompareIs AttributeLoad NameLoad attr NameLoad body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Dict Str Str Call AttributeLoad NameLoad attr Dict Str Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr If CompareNotIn Str NameLoad body Assign SubscriptStore NameLoad Index Str Dict TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad keyword NameLoad Return NameLoad ExceptHandler type NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad keyword NameLoad Return NameLoad orelse AugAssignAdd SubscriptStore AttributeLoad NameLoad attr Index SubscriptLoad NameLoad Index Str Num Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults vararg kwarg body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad Num If NameLoad body Assign NameStore Dict Str Str Call AttributeLoad NameLoad attr NameLoad If Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr TryFinally body Return Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad NameLoad finalbody Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore Dict Str Str Str Call AttributeLoad NameLoad attr NameLoad Dict Str Str NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str TupleLoad Call AttributeLoad NameLoad attr NameLoad Call NameLoad NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore Num FunctionDef arguments args NameParam NameParam defaults NameLoad body If CompareIs NameLoad NameLoad body Assign NameStore AttributeLoad NameLoad attr If CompareLtE NameLoad Num body Raise Call NameLoad BinOpMod Str NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad handlers ExceptHandler type NameLoad body Pass orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr If Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str Call NameLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr If AttributeLoad NameLoad attr body Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr While NameLoad body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam defaults body If Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str NameLoad Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Str Call AttributeLoad NameLoad attr TryExcept body Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad NameLoad Index Str handlers ExceptHandler type TupleLoad NameLoad NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad keyword NameLoad Return Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr SubscriptLoad NameLoad Index Str If CompareIs NameLoad NameLoad body Return If CompareEq NameLoad NameLoad body AugAssignAdd SubscriptStore AttributeLoad NameLoad attr Index NameLoad Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr orelse If CompareEq NameLoad NameLoad body Assign NameStore AttributeLoad NameLoad attr AugAssignAdd SubscriptStore AttributeLoad NameLoad attr Index NameLoad Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr SubscriptLoad NameLoad Index Str SubscriptLoad NameLoad Index Str orelse Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr While BoolOpOr UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr BoolOpAnd AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr While NameLoad body TryExcept body Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr body Break orelse Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr If NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Expr Str decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Expr Str decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str decorator_list FunctionDef arguments args NameParam defaults body Expr Str decorator_list decorator_list Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad keyword NameLoad Assign AttributeStore NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad NameLoad NameLoad keyword NameLoad Assign AttributeStore NameLoad attr NameLoad Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore ListLoad TupleLoad Str Lambda arguments args NameParam defaults IfExp CompareIs NameLoad NameLoad NameLoad Call NameLoad NameLoad Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr CompareIs NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam NameParam defaults vararg kwarg body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Return Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Return Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body If AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults NameLoad body Return Call AttributeLoad NameLoad attr keyword NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore ListLoad TupleLoad Str Lambda arguments args NameParam defaults IfExp CompareIs NameLoad NameLoad NameLoad Call NameLoad NameLoad TupleLoad Str Lambda arguments args NameParam defaults IfExp CompareIs NameLoad NameLoad NameLoad Call NameLoad NameLoad Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr keyword NameLoad keyword NameLoad Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call NameLoad keyword NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Return Call AttributeLoad NameLoad attr keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body If Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Raise Call NameLoad Str Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr If Call AttributeLoad AttributeLoad NameLoad attr attr body Assign AttributeStore NameLoad attr Call NameLoad If UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr If Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Assign NameStore Call NameLoad For TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr body If NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad If NameLoad body Assign NameStore Call NameLoad NameLoad For NameStore NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults vararg kwarg body Expr Str Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call NameLoad AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad keyword NameLoad FunctionDef arguments args defaults body If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad decorator_list FunctionDef arguments args defaults body If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list Expr Call NameLoad Assign NameStore Call NameLoad NameLoad AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad handlers ExceptHandler type NameLoad body With Call AttributeLoad NameLoad attr body Expr Call NameLoad Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults Call NameLoad Return NameLoad decorator_list decorator_list
N/A N/A abc N/A collections multiprocessing managers N/A os N/A pickle N/A threading N/A futurist oslo_utils excutils oslo_utils reflection oslo_utils timeutils oslo_utils uuidutils N/A six six.moves queue compat_queue taskflow logging taskflow task task_atom taskflow.types failure taskflow.types notifier taskflow.utils threading_utils N/A EXECUTED executed N/A REVERTED reverted N/A _PICKLE_ERRORS N/A N/A pickle PickleError TypeError N/A N/A N/A cPickle _cPickle N/A N/A N/A _PICKLE_ERRORS append N/A _cPickle PickleError N/A N/A N/A ImportError N/A N/A N/A _PICKLE_ERRORS N/A tuple _PICKLE_ERRORS N/A _SEND_ERRORS N/A IOError EOFError N/A _UPDATE_PROGRESS N/A task_atom EVENT_UPDATE_PROGRESS N/A _KIND_COMPLETE_ME complete_me N/A _KIND_EVENT event N/A LOG N/A N/A logging getLogger __name__ _execute_retry N/A N/A retry arguments N/A N/A N/A N/A N/A result N/A N/A retry execute arguments N/A N/A N/A Exception N/A N/A result N/A N/A failure Failure N/A N/A EXECUTED result N/A _revert_retry N/A N/A retry arguments N/A N/A N/A N/A N/A result N/A N/A retry revert arguments N/A N/A N/A Exception N/A N/A result N/A N/A failure Failure N/A N/A REVERTED result N/A _execute_task N/A N/A task arguments progress_callback N/A None N/A N/A N/A N/A notifier register_deregister N/A task notifier _UPDATE_PROGRESS callback progress_callback N/A N/A N/A N/A N/A N/A N/A N/A task pre_execute N/A result N/A N/A task execute arguments N/A N/A N/A Exception N/A N/A result N/A N/A failure Failure N/A N/A N/A N/A task post_execute N/A N/A EXECUTED result N/A _revert_task N/A N/A task arguments result failures progress_callback N/A None N/A N/A arguments N/A N/A arguments copy N/A N/A arguments N/A N/A task_atom REVERT_RESULT result N/A N/A arguments N/A N/A task_atom REVERT_FLOW_FAILURES failures N/A N/A N/A notifier register_deregister N/A task notifier _UPDATE_PROGRESS callback progress_callback N/A N/A N/A N/A N/A N/A N/A N/A task pre_revert N/A result N/A N/A task revert arguments N/A N/A N/A Exception N/A N/A result N/A N/A failure Failure N/A N/A N/A N/A task post_revert N/A N/A REVERTED result N/A _ViewableSyncManager N/A N/A managers SyncManager N/A N/A Manager that exposes its state as methods. is_shutdown N/A N/A self N/A N/A N/A N/A N/A N/A self _state value N/A N/A managers State SHUTDOWN N/A is_running N/A N/A self N/A N/A N/A N/A N/A N/A self _state value N/A N/A managers State STARTED N/A N/A _Channel N/A object N/A N/A Helper wrapper around a multiprocessing queue used by a worker. __init__ N/A N/A self queue identity N/A N/A N/A N/A self _queue queue N/A N/A self _identity identity N/A N/A self _sent_messages N/A N/A collections defaultdict int N/A N/A self _pid None N/A sent_messages N/A N/A self N/A N/A N/A N/A self _sent_messages N/A property put N/A N/A self message N/A N/A N/A N/A N/A self _pid None N/A N/A N/A self _pid N/A N/A os getpid N/A N/A N/A message update N/A sent_on sender N/A N/A timeutils utcnow N/A pid id N/A self _pid N/A self _identity N/A N/A body message N/A N/A N/A message N/A body N/A N/A N/A N/A N/A N/A N/A self _queue put message N/A N/A N/A _PICKLE_ERRORS N/A N/A N/A N/A LOG warn Failed serializing message %s message exc_info True N/A False N/A N/A _SEND_ERRORS N/A N/A N/A N/A LOG warn Failed sending message %s message exc_info True N/A False N/A N/A N/A N/A self _sent_messages N/A N/A message N/A kind 1 N/A True N/A N/A _WaitWorkItem N/A object N/A N/A The piece of work that will executed by a process executor.

    This will call the target function, then wait until the tasks emitted
    events/items have been depleted before offically being finished.

    NOTE(harlowja): this is done so that the task function will *not* return
    until all of its notifications have been proxied back to its originating
    task. If we didn't do this then the executor would see this task as done
    and then potentially start tasks that are successors of the task that just
    finished even though notifications are still left to be sent from the
    previously finished task...
     __init__ N/A N/A self channel barrier func task N/A args kwargs N/A N/A N/A self _channel channel N/A N/A self _barrier barrier N/A N/A self _func func N/A N/A self _task task N/A N/A self _args args N/A N/A self _kwargs kwargs N/A _on_finish N/A N/A self N/A N/A N/A sent_events N/A N/A N/A N/A self _channel sent_messages get _KIND_EVENT 0 N/A sent_events N/A N/A message N/A created_on kind N/A N/A timeutils utcnow _KIND_COMPLETE_ME N/A N/A N/A N/A self _channel put message N/A N/A watch N/A N/A timeutils StopWatch N/A N/A N/A watch start N/A N/A N/A N/A self _barrier wait N/A N/A N/A LOG trace Waited %s seconds until task '%s' %s emitted notifications were depleted N/A N/A watch elapsed N/A self _task sent_events N/A __call__ N/A N/A self N/A N/A N/A args N/A self _args N/A kwargs N/A self _kwargs N/A N/A N/A N/A N/A self _func N/A self _task args kwargs N/A N/A N/A N/A self _on_finish N/A N/A _EventSender N/A object N/A N/A Sends event information from a child worker process to its creator. __init__ N/A N/A self channel N/A N/A N/A N/A self _channel channel N/A __call__ N/A N/A self event_type details N/A N/A N/A message N/A created_on kind body N/A N/A timeutils utcnow _KIND_EVENT N/A event_type details event_type details N/A N/A N/A N/A self _channel put message N/A N/A _Target N/A object N/A N/A An immutable helper object that represents a target of a message. __init__ N/A N/A self task barrier identity N/A N/A N/A N/A self task task N/A N/A self barrier barrier N/A N/A self identity identity N/A N/A self dispatched N/A N/A collections defaultdict int N/A __repr__ N/A N/A self N/A N/A N/A N/A <%s at 0x%x targeting '%s' with identity '%s'> N/A N/A N/A reflection get_class_name self N/A id self N/A self task N/A self identity N/A N/A _Dispatcher N/A object N/A N/A Dispatches messages received from child worker processes. N/A _SPIN_PERIODICITY 0.01 __init__ N/A N/A self dispatch_periodicity N/A None N/A N/A N/A dispatch_periodicity None N/A N/A dispatch_periodicity N/A self _SPIN_PERIODICITY N/A N/A dispatch_periodicity 0 N/A N/A N/A ValueError N/A Provided dispatch periodicity must be greater than zero and not '%s' dispatch_periodicity N/A N/A self _targets N/A N/A N/A self _dead N/A N/A threading Event N/A N/A self _dispatch_periodicity dispatch_periodicity N/A N/A self _stop_when_empty False N/A register N/A N/A self identity target N/A N/A N/A N/A N/A self _targets N/A identity target N/A deregister N/A N/A self identity N/A N/A N/A N/A N/A target N/A N/A N/A self _targets pop identity N/A N/A N/A KeyError N/A N/A N/A N/A N/A N/A N/A target barrier set N/A N/A N/A LOG isEnabledFor N/A logging TRACE N/A N/A N/A N/A LOG trace Dispatched %s messages %s to target '%s' during the lifetime of its existence in the dispatcher N/A sum N/A N/A six itervalues N/A target dispatched N/A dict N/A target dispatched target N/A reset N/A N/A self N/A N/A N/A N/A self _stop_when_empty False N/A N/A N/A N/A self _dead clear N/A N/A self _targets N/A N/A leftover N/A set N/A N/A six iterkeys N/A self _targets N/A leftover N/A N/A N/A N/A self deregister N/A N/A leftover pop N/A interrupt N/A N/A self N/A N/A N/A N/A self _stop_when_empty True N/A N/A N/A N/A self _dead set N/A _dispatch N/A N/A self message N/A N/A N/A N/A N/A LOG isEnabledFor N/A logging TRACE N/A N/A N/A N/A LOG trace Dispatching message %s (it took %s seconds for it to arrive for processing after being sent) message N/A N/A timeutils delta_seconds N/A message N/A sent_on N/A N/A timeutils utcnow N/A N/A N/A kind N/A message N/A kind N/A sender N/A message N/A sender N/A body N/A message N/A body N/A N/A N/A N/A KeyError ValueError TypeError N/A N/A N/A N/A LOG warn Badly formatted message %s received message exc_info True N/A N/A target N/A N/A N/A self _targets get N/A sender N/A id N/A N/A target None N/A N/A N/A N/A kind _KIND_COMPLETE_ME N/A N/A N/A N/A target dispatched N/A kind 1 N/A N/A N/A N/A target barrier set N/A N/A N/A kind _KIND_EVENT N/A N/A task N/A target task N/A N/A N/A target dispatched N/A kind 1 N/A N/A N/A N/A task notifier notify N/A body N/A event_type N/A body N/A details N/A N/A N/A N/A LOG warn Unknown message '%s' found in message from sender %s to target '%s' kind sender target N/A run N/A N/A self queue N/A N/A N/A watch N/A N/A timeutils StopWatch duration N/A self _dispatch_periodicity N/A N/A N/A N/A N/A N/A self _dead is_set N/A N/A self _stop_when_empty N/A self _targets N/A N/A N/A N/A watch restart N/A leftover N/A N/A watch leftover N/A leftover N/A N/A N/A N/A message N/A N/A queue get timeout leftover N/A N/A N/A N/A compat_queue Empty N/A N/A N/A N/A N/A N/A self _dispatch message N/A leftover N/A N/A watch leftover N/A leftover N/A N/A watch leftover N/A leftover N/A N/A N/A N/A N/A self _dead wait leftover N/A N/A SerialRetryExecutor N/A object N/A N/A Executes and reverts retries. __init__ N/A N/A self N/A N/A N/A N/A self _executor N/A N/A futurist SynchronousExecutor N/A start N/A N/A self N/A N/A N/A Prepare to execute retries. N/A N/A N/A N/A self _executor restart N/A stop N/A N/A self N/A N/A N/A Finalize retry executor. N/A N/A N/A N/A self _executor shutdown N/A execute_retry N/A N/A self retry arguments N/A N/A N/A Schedules retry execution. N/A fut N/A N/A N/A self _executor submit _execute_retry retry arguments N/A N/A fut atom retry N/A fut N/A revert_retry N/A N/A self retry arguments N/A N/A N/A Schedules retry reversion. N/A fut N/A N/A N/A self _executor submit _revert_retry retry arguments N/A N/A fut atom retry N/A fut N/A N/A TaskExecutor N/A object N/A N/A Executes and reverts tasks.

    This class takes task and its arguments and executes or reverts it.
    It encapsulates knowledge on how task should be executed or reverted:
    right now, on separate thread, on another machine, etc.
     execute_task N/A N/A self task task_uuid arguments progress_callback N/A None N/A N/A Schedules task execution. N/A N/A abc abstractmethod revert_task N/A N/A self task task_uuid arguments result failures progress_callback N/A None N/A N/A Schedules task reversion. N/A N/A abc abstractmethod start N/A N/A self N/A N/A N/A Prepare to execute tasks. N/A stop N/A N/A self N/A N/A N/A Finalize task executor. N/A N/A N/A N/A six add_metaclass N/A abc ABCMeta SerialTaskExecutor N/A TaskExecutor N/A N/A Executes tasks one after another. __init__ N/A N/A self N/A N/A N/A N/A self _executor N/A N/A futurist SynchronousExecutor N/A start N/A N/A self N/A N/A N/A N/A N/A N/A self _executor restart N/A stop N/A N/A self N/A N/A N/A N/A N/A N/A self _executor shutdown N/A execute_task N/A N/A self task task_uuid arguments progress_callback N/A None N/A N/A fut N/A N/A N/A self _executor submit _execute_task task arguments progress_callback progress_callback N/A N/A fut atom task N/A fut N/A revert_task N/A N/A self task task_uuid arguments result failures progress_callback N/A None N/A N/A fut N/A N/A N/A self _executor submit _revert_task task arguments result failures progress_callback progress_callback N/A N/A fut atom task N/A fut N/A N/A ParallelTaskExecutor N/A TaskExecutor N/A N/A Executes tasks in parallel.

    Submits tasks to an executor which should provide an interface similar
    to concurrent.Futures.Executor.
     N/A constructor_options N/A N/A max_workers N/A N/A N/A v N/A N/A N/A v None v N/A int v N/A 
    Optional constructor keyword arguments this executor supports. These will
    typically be passed via engine options (by a engine user) and converted
    into the correct type before being sent into this
    classes ``__init__`` method.
     __init__ N/A N/A self executor max_workers N/A None None N/A N/A N/A self _executor executor N/A N/A self _max_workers max_workers N/A N/A self _own_executor N/A executor None N/A _create_executor N/A N/A self max_workers N/A None N/A N/A Called when an executor has not been provided to make one. N/A N/A abc abstractmethod _submit_task N/A N/A self func task N/A args kwargs N/A N/A fut N/A N/A N/A self _executor submit func task args kwargs N/A N/A fut atom task N/A fut N/A execute_task N/A N/A self task task_uuid arguments progress_callback N/A None N/A N/A N/A N/A self _submit_task _execute_task task arguments progress_callback progress_callback N/A revert_task N/A N/A self task task_uuid arguments result failures progress_callback N/A None N/A N/A N/A N/A self _submit_task _revert_task task arguments result failures progress_callback progress_callback N/A start N/A N/A self N/A N/A N/A N/A self _own_executor N/A N/A N/A self _executor N/A N/A self _create_executor max_workers N/A self _max_workers N/A stop N/A N/A self N/A N/A N/A N/A self _own_executor N/A N/A N/A N/A N/A self _executor shutdown wait True N/A N/A self _executor None N/A N/A ParallelThreadTaskExecutor N/A ParallelTaskExecutor N/A N/A Executes tasks in parallel using a thread pool executor. _create_executor N/A N/A self max_workers N/A None N/A N/A N/A N/A futurist ThreadPoolExecutor max_workers max_workers N/A N/A ParallelProcessTaskExecutor N/A ParallelTaskExecutor N/A N/A Executes tasks in parallel using a process pool executor.

    NOTE(harlowja): this executor executes tasks in external processes, so that
    implies that tasks that are sent to that external process are pickleable
    since this is how the multiprocessing works (sending pickled objects back
    and forth) and that the bound handlers (for progress updating in
    particular) are proxied correctly from that external process to the one
    that is alive in the parent process to ensure that callbacks registered in
    the parent are executed on events in the child.
     N/A constructor_options N/A N/A max_workers N/A N/A N/A v N/A N/A N/A v None v N/A int v N/A dispatch_periodicity N/A N/A N/A v N/A N/A N/A v None v N/A float v N/A 
    Optional constructor keyword arguments this executor supports. These will
    typically be passed via engine options (by a engine user) and converted
    into the correct type before being sent into this
    classes ``__init__`` method.
     __init__ N/A N/A self executor max_workers dispatch_periodicity N/A None None None N/A N/A N/A N/A N/A super ParallelProcessTaskExecutor self __init__ executor executor max_workers max_workers N/A N/A self _manager N/A _ViewableSyncManager N/A N/A self _dispatcher N/A _Dispatcher dispatch_periodicity dispatch_periodicity N/A N/A self _worker None N/A N/A self _queue None N/A _create_executor N/A N/A self max_workers N/A None N/A N/A N/A N/A futurist ProcessPoolExecutor max_workers max_workers N/A start N/A N/A self N/A N/A N/A N/A N/A threading_utils is_alive N/A self _worker N/A N/A N/A RuntimeError Worker thread must be stopped via stop() before starting/restarting N/A N/A N/A N/A super ParallelProcessTaskExecutor self start N/A N/A N/A N/A self _manager is_shutdown N/A N/A N/A self _manager N/A _ViewableSyncManager N/A N/A N/A N/A N/A self _manager is_running N/A N/A N/A N/A N/A self _manager start N/A N/A N/A N/A self _dispatcher reset N/A N/A self _queue N/A N/A N/A self _manager Queue N/A N/A self _worker N/A N/A threading_utils daemon_thread N/A N/A self _dispatcher run N/A self _queue N/A N/A N/A N/A self _worker start N/A stop N/A N/A self N/A N/A N/A N/A N/A N/A self _dispatcher interrupt N/A N/A N/A N/A super ParallelProcessTaskExecutor self stop N/A N/A N/A threading_utils is_alive N/A self _worker N/A N/A N/A N/A N/A self _worker join N/A N/A self _worker None N/A N/A self _queue None N/A N/A N/A N/A self _dispatcher reset N/A N/A N/A N/A self _manager shutdown N/A N/A N/A N/A self _manager join N/A _rebind_task N/A N/A self task clone channel progress_callback N/A None N/A N/A needed N/A set N/A N/A event_type listeners N/A N/A N/A task notifier listeners_iter N/A N/A listeners N/A N/A N/A N/A needed add event_type N/A N/A progress_callback None N/A N/A N/A N/A needed add _UPDATE_PROGRESS N/A needed N/A N/A sender N/A _EventSender channel N/A event_type needed N/A N/A N/A N/A N/A clone notifier register event_type sender N/A _submit_task N/A N/A self func task N/A args kwargs N/A N/A Submit a function to run the given task (with given args/kwargs).

        NOTE(harlowja): Adjust all events to be proxies instead since we want
        those callbacks to be activated in this process, not in the child,
        also since typically callbacks are functors (or callables) we can
        not pickle those in the first place...

        To make sure people understand how this works, the following is a
        lengthy description of what is going on here, read at will:

        So to ensure that we are proxying task triggered events that occur
        in the executed subprocess (which will be created and used by the
        thing using the multiprocessing based executor) we need to establish
        a link between that process and this process that ensures that when a
        event is triggered in that task in that process that a corresponding
        event is triggered on the original task that was requested to be ran
        in this process.

        To accomplish this we have to create a copy of the task (without
        any listeners) and then reattach a new set of listeners that will
        now instead of calling the desired listeners just place messages
        for this process (a dispatcher thread that is created in this class)
        to dispatch to the original task (using a common queue + per task
        sender identity/target that is used and associated to know which task
        to proxy back too, since it is possible that there many be *many*
        subprocess running at the same time, each running a different task
        and using the same common queue to submit messages back to).

        Once the subprocess task has finished execution, the executor will
        then trigger a callback that will remove the task + target from the
        dispatcher (which will stop any further proxying back to the original
        task).
         N/A progress_callback N/A N/A kwargs pop progress_callback None N/A clone N/A N/A task copy retain_listeners False N/A identity N/A N/A uuidutils generate_uuid N/A target N/A _Target task N/A N/A N/A self _manager Event identity N/A channel N/A _Channel N/A self _queue identity N/A N/A N/A self _rebind_task task clone channel progress_callback progress_callback register N/A N/A N/A N/A N/A N/A progress_callback None N/A N/A N/A N/A N/A task notifier register _UPDATE_PROGRESS progress_callback N/A N/A N/A N/A self _dispatcher register identity target N/A deregister N/A N/A N/A N/A N/A N/A progress_callback None N/A N/A N/A N/A N/A task notifier deregister _UPDATE_PROGRESS progress_callback N/A N/A N/A N/A self _dispatcher deregister identity N/A N/A N/A register N/A work N/A _WaitWorkItem channel N/A target barrier func clone args kwargs N/A N/A N/A fut N/A N/A N/A self _executor submit work N/A N/A N/A RuntimeError N/A N/A N/A N/A excutils save_and_reraise_exception N/A N/A N/A deregister N/A N/A fut atom task N/A N/A N/A fut add_done_callback N/A N/A N/A fut N/A N/A deregister N/A fut N/A N/A