Module Import alias Import alias ImportFrom alias ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias ImportFrom alias alias Assign NameStore Call AttributeLoad NameLoad attr Str Str ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad 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 Dict Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr GeneratorExp TupleLoad NameLoad NameLoad comprehension NameStore Call NameLoad NameLoad Assign NameStore Call NameLoad While NameLoad body Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr Assign NameStore SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index Str Assign NameStore SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index NameLoad TryExcept body Assign NameStore SubscriptLoad NameLoad Index NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad If CompareIs NameLoad NameLoad body Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr Expr Yield Call NameLoad NameLoad NameLoad NameLoad NameLoad handlers ExceptHandler type NameLoad body Pass If BoolOpAnd CompareEq NameLoad AttributeLoad NameLoad attr CompareNotIn NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr GeneratorExp TupleLoad NameLoad NameLoad comprehension NameStore Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Dict AttributeLoad NameLoad attr AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr keyword Num AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Dict AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Dict AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Dict AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr keyword NameLoad body Assign NameStore SubscriptLoad NameLoad Index Str If CompareIn NameLoad AttributeLoad NameLoad attr body Continue orelse If CompareIn NameLoad AttributeLoad NameLoad attr body Assign NameStore SubscriptLoad NameLoad Index NameLoad Assign NameStore SubscriptLoad NameLoad Index NameLoad Assign NameStore SubscriptLoad NameLoad Index NameLoad Assign NameStore SubscriptLoad NameLoad Index NameLoad orelse Raise Call AttributeLoad NameLoad attr BinOpMod Str NameLoad Assign NameStore Dict Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad keyword NameLoad Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore NameLoad Index Str Call NameLoad NameLoad Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam NameParam defaults body Return SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Str Return Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr Return SubscriptLoad NameLoad Index Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str TryExcept body Return Call AttributeLoad NameLoad attr NameLoad Str handlers ExceptHandler type NameLoad body Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Str Assign NameStore ListLoad For NameStore NameLoad body If BoolOpOr NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr TupleLoad NameLoad NameLoad NameLoad If NameLoad body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Str Expr Call NameLoad NameLoad NameLoad If NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Str Return Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Str Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad AttributeLoad AttributeLoad NameLoad attr attr Return Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr ListLoad NameLoad keyword NameLoad keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list decorator_list
N/A N/A collections N/A functools futurist waiters taskflow deciders de taskflow.engines.action_engine.actions retry ra taskflow.engines.action_engine.actions task ta taskflow.engines.action_engine analyzer an taskflow.engines.action_engine builder bu taskflow.engines.action_engine compiler com taskflow.engines.action_engine completer co taskflow.engines.action_engine scheduler sched taskflow.engines.action_engine scopes sc taskflow.engines.action_engine traversal tr taskflow exceptions exc taskflow states st taskflow.utils misc taskflow.flow LINK_DECIDER LINK_DECIDER_DEPTH N/A _EdgeDecider N/A N/A collections namedtuple _EdgeDecider from_node,kind,decider,depth Runtime N/A object N/A N/A A aggregate of runtime objects, properties, ... used during execution.

    This object contains various utility methods and properties that represent
    the collection of runtime components and functionality needed for an
    action engine to run to completion.
     __init__ N/A N/A self compilation storage atom_notifier task_executor retry_executor options N/A None N/A N/A N/A self _atom_notifier atom_notifier N/A N/A self _task_executor task_executor N/A N/A self _retry_executor retry_executor N/A N/A self _storage storage N/A N/A self _compilation compilation N/A N/A self _atom_cache N/A N/A N/A self _options N/A N/A misc safe_copy_dict options N/A _walk_edge_deciders N/A N/A self graph atom N/A N/A N/A Iterates through all nodes, deciders that alter atoms execution. N/A predecessors_iter N/A graph predecessors_iter N/A nodes N/A N/A collections deque N/A N/A u_node atom N/A u_node N/A predecessors_iter atom N/A visited N/A set N/A nodes N/A N/A N/A u_node v_node N/A N/A nodes popleft N/A u_node_kind N/A N/A N/A graph node N/A u_node N/A kind N/A u_v_data N/A N/A N/A graph adj N/A u_node N/A v_node N/A N/A N/A decider N/A u_v_data N/A LINK_DECIDER N/A decider_depth N/A N/A u_v_data get LINK_DECIDER_DEPTH N/A N/A decider_depth None N/A N/A decider_depth N/A N/A de Depth ALL N/A N/A N/A _EdgeDecider u_node u_node_kind decider decider_depth N/A N/A N/A KeyError N/A N/A N/A N/A N/A u_node_kind N/A com FLOW N/A u_node visited N/A N/A N/A N/A visited add u_node N/A N/A N/A nodes extend N/A N/A u_u_node u_node N/A u_u_node N/A predecessors_iter u_node N/A compile N/A N/A self N/A N/A N/A Compiles & caches frequently used execution helper objects.

        Build out a cache of commonly used item that are associated
        with the contained atoms (by name), and are useful to have for
        quick lookup on (for example, the change state handler function for
        each atom, the scope walker object for each atom, the task or retry
        specific scheduler and so-on).
         N/A change_state_handlers N/A N/A com TASK N/A com RETRY N/A N/A functools partial N/A N/A self task_action change_state progress 0.0 N/A N/A self retry_action change_state N/A schedulers N/A N/A com RETRY N/A com TASK N/A self retry_scheduler N/A self task_scheduler N/A check_transition_handlers N/A N/A com TASK N/A com RETRY N/A st check_task_transition N/A st check_retry_transition N/A actions N/A N/A com TASK N/A com RETRY N/A self task_action N/A self retry_action N/A graph N/A N/A self _compilation execution_graph N/A N/A node node_data N/A N/A graph nodes_iter data True N/A N/A node_kind N/A node_data N/A kind N/A N/A node_kind N/A com FLOWS N/A N/A N/A N/A N/A node_kind N/A com ATOMS N/A N/A check_transition_handler N/A check_transition_handlers N/A node_kind N/A change_state_handler N/A change_state_handlers N/A node_kind N/A scheduler N/A schedulers N/A node_kind N/A action N/A actions N/A node_kind N/A N/A N/A N/A exc CompilationFailure N/A Unknown node kind '%s' encountered node_kind N/A metadata N/A N/A deciders_it N/A N/A self _walk_edge_deciders graph node N/A walker N/A N/A sc ScopeWalker N/A self compilation node names_only True N/A N/A metadata N/A scope_walker walker N/A N/A metadata N/A check_transition_handler check_transition_handler N/A N/A metadata N/A change_state_handler change_state_handler N/A N/A metadata N/A scheduler scheduler N/A N/A metadata N/A edge_deciders N/A tuple deciders_it N/A N/A metadata N/A action action N/A N/A N/A self _atom_cache N/A N/A node name metadata N/A compilation N/A N/A self N/A N/A N/A N/A self _compilation N/A property storage N/A N/A self N/A N/A N/A N/A self _storage N/A property options N/A N/A self N/A N/A N/A N/A self _options N/A property analyzer N/A N/A self N/A N/A N/A N/A N/A an Analyzer self N/A N/A misc cachedproperty builder N/A N/A self N/A N/A N/A N/A N/A bu MachineBuilder self N/A waiters wait_for_any N/A N/A misc cachedproperty completer N/A N/A self N/A N/A N/A N/A N/A co Completer self N/A N/A misc cachedproperty scheduler N/A N/A self N/A N/A N/A N/A N/A sched Scheduler self N/A N/A misc cachedproperty task_scheduler N/A N/A self N/A N/A N/A N/A N/A sched TaskScheduler self N/A N/A misc cachedproperty retry_scheduler N/A N/A self N/A N/A N/A N/A N/A sched RetryScheduler self N/A N/A misc cachedproperty retry_action N/A N/A self N/A N/A N/A N/A N/A ra RetryAction N/A self _storage N/A self _atom_notifier N/A self _retry_executor N/A N/A misc cachedproperty task_action N/A N/A self N/A N/A N/A N/A N/A ta TaskAction N/A self _storage N/A self _atom_notifier N/A self _task_executor N/A N/A misc cachedproperty _fetch_atom_metadata_entry N/A N/A self atom_name metadata_key N/A N/A N/A N/A N/A N/A self _atom_cache N/A atom_name N/A metadata_key N/A check_atom_transition N/A N/A self atom current_state target_state N/A N/A N/A Checks if the atom can transition to the provided target state. N/A check_transition_handler N/A N/A self _fetch_atom_metadata_entry N/A atom name check_transition_handler N/A N/A check_transition_handler current_state target_state N/A fetch_edge_deciders N/A N/A self atom N/A N/A N/A Fetches the edge deciders for the given atom. N/A N/A N/A self _fetch_atom_metadata_entry N/A atom name edge_deciders N/A fetch_scheduler N/A N/A self atom N/A N/A N/A Fetches the cached specific scheduler for the given atom. N/A N/A N/A self _fetch_atom_metadata_entry N/A atom name scheduler N/A fetch_action N/A N/A self atom N/A N/A N/A Fetches the cached action handler for the given atom. N/A metadata N/A N/A self _atom_cache N/A N/A atom name N/A N/A metadata N/A action N/A fetch_scopes_for N/A N/A self atom_name N/A N/A N/A Fetches a walker of the visible scopes for the given atom. N/A N/A N/A N/A N/A self _fetch_atom_metadata_entry atom_name scope_walker N/A N/A N/A KeyError N/A N/A None N/A reset_atoms N/A N/A self atoms state intention N/A N/A st PENDING N/A st EXECUTE N/A N/A Resets all the provided atoms to the given state and intention. N/A tweaked N/A N/A atom atoms N/A N/A N/A state intention N/A N/A N/A N/A tweaked append N/A atom state intention N/A state N/A N/A change_state_handler N/A N/A self _fetch_atom_metadata_entry N/A atom name change_state_handler N/A N/A change_state_handler atom state N/A intention N/A N/A N/A N/A N/A self storage set_atom_intention N/A atom name intention N/A tweaked N/A reset_all N/A N/A self state intention N/A N/A st PENDING N/A st EXECUTE N/A N/A Resets all atoms to the given state and intention. N/A N/A N/A self reset_atoms N/A N/A N/A self analyzer iterate_nodes N/A com ATOMS state state intention intention N/A reset_subgraph N/A N/A self atom state intention N/A N/A st PENDING N/A st EXECUTE N/A N/A Resets a atoms subgraph to the given state and intention.

        The subgraph is contained of **all** of the atoms successors.
         N/A execution_graph N/A N/A self _compilation execution_graph N/A atoms_it N/A N/A tr depth_first_iterate execution_graph atom N/A N/A tr Direction FORWARD N/A N/A N/A self reset_atoms atoms_it state state intention intention N/A retry_subflow N/A N/A self retry N/A N/A N/A Prepares a retrys + its subgraph for execution.

        This sets the retrys intention to ``EXECUTE`` and resets all of its
        subgraph (its successors) to the ``PENDING`` state with an ``EXECUTE``
        intention.
         N/A tweaked N/A N/A self reset_atoms N/A retry state None intention N/A st EXECUTE N/A N/A N/A tweaked extend N/A N/A self reset_subgraph retry N/A tweaked N/A N/A