Index

_

__call__() (taskflow.types.notifier.Listener method)

__iter__() (taskflow.engines.action_engine.scopes.ScopeWalker method)

A

abandon() (taskflow.jobs.base.JobBoard method) ActionEngine (class in taskflow.engines.action_engine.engine) add() (taskflow.flow.Flow method) (taskflow.patterns.graph_flow.Flow method) (taskflow.patterns.graph_flow.TargetedFlow method) (taskflow.patterns.linear_flow.Flow method) (taskflow.patterns.unordered_flow.Flow method) (taskflow.persistence.models.FlowDetail method) (taskflow.persistence.models.LogBook method) (taskflow.types.tree.Node method) add_edge() (taskflow.types.graph.DiGraph method) (taskflow.types.graph.Graph method) add_node() (taskflow.types.graph.DiGraph method) (taskflow.types.graph.Graph method) adjlist_inner_dict_factory (taskflow.types.graph.OrderedDiGraph attribute) (taskflow.types.graph.OrderedGraph attribute) adjlist_outer_dict_factory (taskflow.types.graph.OrderedDiGraph attribute) (taskflow.types.graph.OrderedGraph attribute)

affect() (taskflow.engines.action_engine.deciders.Decider method) (taskflow.engines.action_engine.deciders.IgnoreDecider method) (taskflow.engines.action_engine.deciders.NoOpDecider method) ALL (taskflow.deciders.Depth attribute) AlwaysRevert (class in taskflow.retry) AlwaysRevertAll (class in taskflow.retry) AmbiguousDependency ANY (taskflow.types.notifier.Notifier attribute) apply() (taskflow.engines.action_engine.completer.Revert method) (taskflow.engines.action_engine.completer.RevertAll method) (taskflow.engines.action_engine.completer.RevertAndRetry method) (taskflow.engines.action_engine.completer.Strategy method) args (taskflow.types.notifier.Listener property) as_int() (in module taskflow.utils.misc) Atom (class in taskflow.atom) ATOM (taskflow.deciders.Depth attribute) atom_notifier (taskflow.engines.base.Engine property) AtomDetail (class in taskflow.persistence.models)

B

Backend (class in taskflow.persistence.base) backend (taskflow.persistence.base.Connection property) (taskflow.persistence.path_based.PathBasedConnection property) (taskflow.storage.Storage property) backend() (in module taskflow.jobs.backends) (in module taskflow.persistence.backends) BACKWARD (taskflow.engines.action_engine.traversal.Direction attribute) BadHmacValueError BASE_EXCEPTIONS (taskflow.types.failure.Failure attribute) bfs_iter() (taskflow.types.tree.Node method) bfs_predecessors_iter() (taskflow.types.graph.DiGraph method) binary_decode() (in module taskflow.utils.misc)

binary_encode() (in module taskflow.utils.misc) bind() (taskflow.utils.threading_utils.ThreadBundle method) BlockingConductor (class in taskflow.conductors.backends.impl_blocking) board (taskflow.jobs.base.Job property) (taskflow.jobs.base.JobBoardIterator property) book (taskflow.jobs.base.Job property) book_name (taskflow.jobs.base.Job property) book_uuid (taskflow.jobs.base.Job property) breadth_first_iterate() (in module taskflow.engines.action_engine.traversal) build() (taskflow.engines.action_engine.builder.MachineBuilder method) build_a_machine() (in module taskflow.engines.worker_based.protocol) BytesIO (class in taskflow.utils.misc)

C

cachedproperty (class in taskflow.utils.misc) callback (taskflow.types.notifier.Listener property) can_be_registered() (taskflow.types.notifier.Notifier method) (taskflow.types.notifier.RestrictedNotifier method) can_trigger_notification() (taskflow.types.notifier.Notifier method) cancel_futures() (taskflow.engines.action_engine.builder.MachineMemory method) capture_failure() (in module taskflow.utils.misc) CaptureListener (class in taskflow.listeners.capturing) caused_by() (taskflow.retry.History method) causes (taskflow.types.failure.Failure property) ChallengeIgnored change_flow_state() (taskflow.storage.Storage method) Channel (class in taskflow.engines.action_engine.process_executor) check() (taskflow.exceptions.WrappedFailure method) (taskflow.types.failure.Failure method) check_and_affect() (taskflow.engines.action_engine.deciders.Decider method) check_atom_transition() (taskflow.engines.action_engine.runtime.Runtime method) check_for_eventlet() (in module taskflow.utils.eventlet_utils) CheckingClaimListener (class in taskflow.listeners.claims) child_count() (taskflow.types.tree.Node method) CHUNK_SIZE (taskflow.engines.action_engine.process_executor.DispatcherHandler attribute) claim() (taskflow.jobs.base.JobBoard method) clamp() (in module taskflow.utils.misc) clean() (taskflow.engines.worker_based.types.ProxyWorkerFinder method) cleanup_retry_history() (taskflow.storage.Storage method) clear() (taskflow.persistence.backends.impl_memory.FakeFilesystem method) clear_all() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) close() (taskflow.conductors.base.Conductor method) (taskflow.jobs.base.JobBoard method) (taskflow.persistence.backends.impl_dir.DirBackend method) (taskflow.persistence.backends.impl_memory.MemoryBackend method) (taskflow.persistence.base.Backend method) (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) Compilation (class in taskflow.engines.action_engine.compiler)

compilation (taskflow.engines.action_engine.engine.ActionEngine property) CompilationFailure compile() (taskflow.engines.action_engine.compiler.FlowCompiler method) (taskflow.engines.action_engine.compiler.PatternCompiler method) (taskflow.engines.action_engine.engine.ActionEngine method) (taskflow.engines.action_engine.runtime.Runtime method) (taskflow.engines.base.Engine method) complete() (taskflow.engines.action_engine.completer.Completer method) complete_failure() (taskflow.engines.action_engine.completer.Completer method) Completer (class in taskflow.engines.action_engine.completer) Conductor (class in taskflow.conductors.base) conductor (taskflow.conductors.base.Conductor attribute) ConductorFailure connect() (taskflow.conductors.base.Conductor method) (taskflow.jobs.base.JobBoard method) connected (taskflow.jobs.base.JobBoard property) Connection (class in taskflow.persistence.backends.impl_dir) (class in taskflow.persistence.backends.impl_memory) (class in taskflow.persistence.base) constructor_options (taskflow.engines.action_engine.executor.ParallelTaskExecutor attribute) (taskflow.engines.action_engine.process_executor.ParallelProcessTaskExecutor attribute) consume() (taskflow.jobs.base.JobBoard method) convert_to_timeout() (in module taskflow.types.timing) copy() (taskflow.persistence.models.AtomDetail method) (taskflow.persistence.models.FlowDetail method) (taskflow.persistence.models.LogBook method) (taskflow.persistence.models.RetryDetail method) (taskflow.persistence.models.TaskDetail method) (taskflow.task.Task method) (taskflow.types.failure.Failure method) (taskflow.types.sets.OrderedSet method) count() (in module taskflow.utils.iter_utils) countdown_iter() (in module taskflow.utils.misc) create_flow_detail() (in module taskflow.utils.persistence_utils) created_on (taskflow.jobs.base.Job property) current_state (taskflow.engines.worker_based.protocol.Request property)

D

daemon_thread() (in module taskflow.utils.threading_utils) Decider (class in taskflow.engines.action_engine.deciders) Decision (class in taskflow.retry) decode_json() (in module taskflow.utils.misc) decode_msgpack() (in module taskflow.utils.misc) DEFAULT_FILE_ENCODING (taskflow.persistence.backends.impl_dir.DirBackend attribute) DEFAULT_LISTEN_FOR (in module taskflow.listeners.base) DEFAULT_PATH (taskflow.persistence.backends.impl_memory.MemoryBackend attribute) (taskflow.persistence.path_based.PathBasedBackend attribute) DEFAULT_WORKERS (taskflow.engines.action_engine.executor.ParallelGreenThreadTaskExecutor attribute) DelayedPretty (class in taskflow.utils.kombu_utils) delete() (taskflow.persistence.backends.impl_memory.FakeFilesystem method) DependencyFailure Depth (class in taskflow.deciders) depth_first_iterate() (in module taskflow.engines.action_engine.traversal) depth_first_reverse_iterate() (in module taskflow.engines.action_engine.traversal) deregister() (taskflow.types.notifier.Notifier method) deregister_event() (taskflow.types.notifier.Notifier method)

destroy_logbook() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) details (taskflow.jobs.base.Job property) details_filter (taskflow.types.notifier.Listener property) dfs_iter() (taskflow.types.tree.Node method) difference() (taskflow.types.sets.OrderedSet method) DiGraph (class in taskflow.types.graph) DirBackend (class in taskflow.persistence.backends.impl_dir) Direction (class in taskflow.engines.action_engine.traversal) disallow_when_frozen() (in module taskflow.utils.misc) DisallowedAccess disassociate() (taskflow.types.tree.Node method) Dispatcher (class in taskflow.engines.action_engine.process_executor) DispatcherHandler (class in taskflow.engines.action_engine.process_executor) dispatching (taskflow.conductors.backends.impl_executor.ExecutorConductor property) DumpingListener (class in taskflow.listeners.base) Duplicate DurationListener (class in taskflow.listeners.timing) DynamicLoggingListener (class in taskflow.listeners.logging)

E

edge_attr_dict_factory (taskflow.types.graph.OrderedDiGraph attribute) (taskflow.types.graph.OrderedGraph attribute) Empty empty() (taskflow.types.tree.Node method) EMPTY_SPACE_SEP (taskflow.types.tree.Node attribute) Endpoint (class in taskflow.engines.worker_based.endpoint) Engine (class in taskflow.engines.base) ensure_atom() (taskflow.storage.Storage method) ensure_atoms() (taskflow.storage.Storage method) ensure_path() (taskflow.persistence.backends.impl_memory.FakeFilesystem method) Entity (class in taskflow.types.entity) ENTITY_KIND (taskflow.conductors.base.Conductor attribute) EVENTS_EMITTED (taskflow.conductors.backends.impl_executor.ExecutorConductor attribute) events_iter() (taskflow.types.notifier.RestrictedNotifier method) EventSender (class in taskflow.engines.action_engine.process_executor) EventTimeListener (class in taskflow.listeners.timing) exc_info (taskflow.types.failure.Failure property) exception (taskflow.types.failure.Failure property) exception_args (taskflow.types.failure.Failure property) exception_str (taskflow.types.failure.Failure property)

execute() (taskflow.atom.Atom method) (taskflow.retry.AlwaysRevert method) (taskflow.retry.AlwaysRevertAll method) (taskflow.retry.ForEach method) (taskflow.retry.ParameterizedForEach method) (taskflow.retry.Retry method) (taskflow.retry.Times method) (taskflow.task.FunctorTask method) (taskflow.task.MapFunctorTask method) (taskflow.task.ReduceFunctorTask method) execute_retry() (taskflow.engines.action_engine.executor.SerialRetryExecutor method) execute_task() (taskflow.engines.action_engine.executor.ParallelTaskExecutor method) (taskflow.engines.action_engine.executor.SerialTaskExecutor method) (taskflow.engines.action_engine.executor.TaskExecutor method) execution_graph (taskflow.engines.action_engine.compiler.Compilation property) ExecutionFailure ExecutorConductor (class in taskflow.conductors.backends.impl_executor) expired (taskflow.engines.worker_based.protocol.Request property) export_to_dot() (taskflow.types.graph.DiGraph method) (taskflow.types.graph.Graph method) extract_driver_and_conf() (in module taskflow.utils.misc)

F

Failure (class in taskflow.types.failure) failure (taskflow.retry.History property) failure_to_dict() (in module taskflow.engines.worker_based.protocol) FailureFormatter (class in taskflow.formatters) FakeFilesystem (class in taskflow.persistence.backends.impl_memory) FakeInode (class in taskflow.persistence.backends.impl_memory) fetch() (in module taskflow.conductors.backends) (in module taskflow.jobs.backends) (in module taskflow.persistence.backends) (taskflow.storage.Storage method) fetch_action() (taskflow.engines.action_engine.runtime.Runtime method) fetch_all() (taskflow.storage.Storage method) fetch_edge_deciders() (taskflow.engines.action_engine.runtime.Runtime method) fetch_mapped_args() (taskflow.storage.Storage method) fetch_scheduler() (taskflow.engines.action_engine.runtime.Runtime method) fetch_scopes_for() (taskflow.engines.action_engine.runtime.Runtime method) fetch_unsatisfied_args() (taskflow.storage.Storage method) fill() (in module taskflow.utils.iter_utils) find() (taskflow.persistence.models.FlowDetail method) (taskflow.persistence.models.LogBook method) (taskflow.types.tree.Node method) find_first_match() (in module taskflow.utils.iter_utils) (taskflow.types.tree.Node method) find_owner() (taskflow.jobs.base.JobBoard method) find_retry() (taskflow.engines.action_engine.runtime.Runtime method) find_subclasses() (in module taskflow.utils.misc) FINISH_STATES (in module taskflow.listeners.base) fix_newlines() (in module taskflow.utils.misc) Flow (class in taskflow.flow) (class in taskflow.patterns.graph_flow) (class in taskflow.patterns.linear_flow) (class in taskflow.patterns.unordered_flow)

FLOW (taskflow.deciders.Depth attribute) (taskflow.engines.action_engine.compiler.Compilation attribute) flow (taskflow.engines.action_engine.compiler.Terminator property) FLOW (taskflow.listeners.capturing.CaptureListener attribute) FLOW_END (taskflow.engines.action_engine.compiler.Compilation attribute) flow_from_detail() (in module taskflow.engines.helpers) flow_meta (taskflow.storage.Storage property) flow_name (taskflow.storage.Storage property) flow_uuid (taskflow.storage.Storage property) FlowCompiler (class in taskflow.engines.action_engine.compiler) FlowDetail (class in taskflow.persistence.models) ForEach (class in taskflow.retry) format() (taskflow.formatters.FailureFormatter method) FORWARD (taskflow.engines.action_engine.traversal.Direction attribute) freeze() (taskflow.types.graph.DiGraph method) (taskflow.types.graph.Graph method) fresh_copy() (taskflow.types.graph.DiGraph method) (taskflow.types.graph.Graph method) (taskflow.types.graph.OrderedDiGraph method) (taskflow.types.graph.OrderedGraph method) from_dict() (taskflow.engines.worker_based.protocol.Request static method) (taskflow.persistence.models.AtomDetail class method) (taskflow.persistence.models.FlowDetail class method) (taskflow.persistence.models.LogBook class method) (taskflow.persistence.models.RetryDetail class method) (taskflow.types.failure.Failure class method) from_exception() (taskflow.types.failure.Failure class method) FrozenNode FunctorTask (class in taskflow.task)

G

generate_delays() (in module taskflow.utils.iter_utils) get() (taskflow.persistence.backends.impl_memory.FakeFilesystem method) (taskflow.storage.Storage method) get_atom_details() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) get_atom_intention() (taskflow.storage.Storage method) get_atom_state() (taskflow.storage.Storage method) get_atom_uuid() (taskflow.storage.Storage method) get_atoms_for_flow() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) get_atoms_states() (taskflow.storage.Storage method) get_connection() (taskflow.persistence.backends.impl_dir.DirBackend method) (taskflow.persistence.backends.impl_memory.MemoryBackend method) (taskflow.persistence.base.Backend method) get_edge_data() (taskflow.types.graph.DiGraph method) get_execute_failures() (taskflow.storage.Storage method) get_execute_result() (taskflow.storage.Storage method) get_failures() (taskflow.storage.Storage method) get_flow_details() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method)

get_flow_state() (taskflow.storage.Storage method) get_flows_for_book() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) get_hostname() (in module taskflow.utils.misc) get_ident() (in module taskflow.utils.threading_utils) get_logbook() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) get_logbooks() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) get_optimal_thread_count() (in module taskflow.utils.threading_utils) get_retry_histories() (taskflow.storage.Storage method) get_retry_history() (taskflow.storage.Storage method) get_revert_failures() (taskflow.storage.Storage method) get_revert_result() (taskflow.storage.Storage method) get_task_progress() (taskflow.storage.Storage method) get_task_progress_details() (taskflow.storage.Storage method) get_version_string() (in module taskflow.utils.misc) get_worker_for_task() (taskflow.engines.worker_based.types.ProxyWorkerFinder method) Graph (class in taskflow.types.graph)

H

has_failures() (taskflow.storage.Storage method) hierarchy (taskflow.engines.action_engine.compiler.Compilation property)

HIGH (taskflow.jobs.base.JobPriority attribute) History (class in taskflow.retry) HORIZONTAL_CONN (taskflow.types.tree.Node attribute)

I

IGNORABLE_STATES (taskflow.engines.action_engine.engine.ActionEngine attribute) IgnoreDecider (class in taskflow.engines.action_engine.deciders) IncompatibleVersion index() (taskflow.types.tree.Node method) inject() (taskflow.storage.Storage method) inject_atom_args() (taskflow.storage.Storage method) injector_name (taskflow.storage.Storage attribute) interrupt() (taskflow.types.timing.Timeout method) intersection() (taskflow.types.sets.OrderedSet method) InvalidFormat InvalidState is_alive() (in module taskflow.utils.threading_utils) is_directed_acyclic() (taskflow.types.graph.DiGraph method) is_equivalent() (taskflow.types.notifier.Listener method) is_iterable() (in module taskflow.utils.misc) is_registered() (taskflow.types.notifier.Notifier method)

is_stopped() (taskflow.types.timing.Timeout method) is_success() (taskflow.engines.action_engine.runtime.Runtime method) issubset() (taskflow.types.sets.OrderedSet method) issuperset() (taskflow.types.sets.OrderedSet method) iter_forever() (in module taskflow.utils.iter_utils) iter_links() (taskflow.flow.Flow method) (taskflow.patterns.graph_flow.Flow method) (taskflow.patterns.linear_flow.Flow method) (taskflow.patterns.unordered_flow.Flow method) iter_next_atoms() (taskflow.engines.action_engine.selector.Selector method) iter_nodes() (taskflow.flow.Flow method) (taskflow.patterns.graph_flow.Flow method) (taskflow.patterns.linear_flow.Flow method) (taskflow.patterns.unordered_flow.Flow method) iterate_nodes() (taskflow.engines.action_engine.runtime.Runtime method) iterate_retries() (taskflow.engines.action_engine.runtime.Runtime method) iterjobs() (taskflow.jobs.base.JobBoard method)

J

Job (class in taskflow.jobs.base) job_count (taskflow.jobs.base.JobBoard property) JobBoard (class in taskflow.jobs.base)

JobBoardIterator (class in taskflow.jobs.base) JobFailure JobPriority (class in taskflow.jobs.base) join() (taskflow.persistence.backends.impl_memory.FakeFilesystem static method)

K

kwargs (taskflow.types.notifier.Listener property)

L

last_failures (taskflow.persistence.models.RetryDetail property) last_modified (taskflow.jobs.base.Job property) last_results (taskflow.persistence.models.AtomDetail property) (taskflow.persistence.models.RetryDetail property) LINE_SEP (taskflow.types.tree.Node attribute) link() (taskflow.patterns.graph_flow.Flow method) (taskflow.patterns.graph_flow.TargetedFlow method) Listener (class in taskflow.listeners.base) (class in taskflow.types.notifier) listeners_iter() (taskflow.types.notifier.Notifier method)

load() (in module taskflow.engines.helpers) load_from_detail() (in module taskflow.engines.helpers) load_from_factory() (in module taskflow.engines.helpers) lock (taskflow.storage.Storage property) LOG (taskflow.conductors.backends.impl_executor.ExecutorConductor attribute) LogBook (class in taskflow.persistence.models) LoggingListener (class in taskflow.listeners.logging) LOW (taskflow.jobs.base.JobPriority attribute) ls() (taskflow.persistence.backends.impl_memory.FakeFilesystem method) ls_r() (taskflow.persistence.backends.impl_memory.FakeFilesystem method)

M

MachineBuilder (class in taskflow.engines.action_engine.builder) MachineMemory (class in taskflow.engines.action_engine.builder) make_an_event() (in module taskflow.engines.worker_based.protocol) make_banner() (in module taskflow.utils.banner) make_completed_future() (in module taskflow.utils.async_utils) MapFunctorTask (class in taskflow.task) match_type() (in module taskflow.utils.misc) matches() (taskflow.types.failure.Failure method) MAX_BACKLOG (taskflow.engines.action_engine.process_executor.Dispatcher attribute) MAX_MACHINE_STATES_RETAINED (taskflow.engines.action_engine.engine.ActionEngine attribute) MAX_SIMULTANEOUS_JOBS (taskflow.conductors.backends.impl_blocking.BlockingConductor attribute) (taskflow.conductors.backends.impl_executor.ExecutorConductor attribute) (taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor attribute) maybe_publish() (taskflow.engines.worker_based.types.ProxyWorkerFinder method) MemoryBackend (class in taskflow.persistence.backends.impl_memory) merge() (taskflow.persistence.models.AtomDetail method) (taskflow.persistence.models.FlowDetail method) (taskflow.persistence.models.LogBook method) (taskflow.persistence.models.RetryDetail method) (taskflow.persistence.models.TaskDetail method) merge_graphs() (in module taskflow.types.graph) merge_uri() (in module taskflow.utils.misc) Message (class in taskflow.engines.worker_based.protocol) MESSAGE_TPL (taskflow.exceptions.MissingDependencies attribute) messages_processed (taskflow.engines.worker_based.types.ProxyWorkerFinder property) millis_to_datetime() (in module taskflow.utils.misc) MissingDependencies module taskflow.atom taskflow.conductors.backends taskflow.conductors.backends.impl_blocking taskflow.conductors.backends.impl_executor taskflow.conductors.backends.impl_nonblocking taskflow.conductors.base taskflow.deciders taskflow.engines.action_engine.builder taskflow.engines.action_engine.compiler taskflow.engines.action_engine.completer taskflow.engines.action_engine.deciders taskflow.engines.action_engine.engine taskflow.engines.action_engine.executor taskflow.engines.action_engine.process_executor taskflow.engines.action_engine.runtime taskflow.engines.action_engine.scheduler taskflow.engines.action_engine.selector taskflow.engines.action_engine.traversal taskflow.engines.base taskflow.engines.helpers taskflow.engines.worker_based.endpoint taskflow.engines.worker_based.protocol taskflow.engines.worker_based.types taskflow.exceptions taskflow.flow taskflow.formatters taskflow.jobs.backends taskflow.jobs.base taskflow.listeners.base taskflow.patterns.graph_flow taskflow.patterns.linear_flow taskflow.patterns.unordered_flow taskflow.persistence.backends taskflow.persistence.backends.impl_dir taskflow.persistence.backends.impl_memory taskflow.persistence.base taskflow.persistence.models taskflow.persistence.path_based taskflow.storage taskflow.task taskflow.types.entity taskflow.types.failure taskflow.types.graph taskflow.types.notifier taskflow.types.sets taskflow.types.timing taskflow.types.tree taskflow.utils.async_utils taskflow.utils.banner taskflow.utils.eventlet_utils taskflow.utils.iter_utils taskflow.utils.kombu_utils taskflow.utils.misc taskflow.utils.persistence_utils taskflow.utils.schema_utils taskflow.utils.threading_utils

MultipleChoices

N

name (taskflow.engines.action_engine.compiler.Terminator property) (taskflow.flow.Flow property) (taskflow.jobs.base.Job property) (taskflow.jobs.base.JobBoard property) (taskflow.persistence.models.AtomDetail property) (taskflow.persistence.models.FlowDetail property) (taskflow.persistence.models.LogBook property) NEIGHBORS (taskflow.deciders.Depth attribute) NO_CONSUME_EXCEPTIONS (taskflow.conductors.backends.impl_executor.ExecutorConductor attribute) no_op() (in module taskflow.utils.threading_utils) no_predecessors_iter() (taskflow.types.graph.DiGraph method) NO_RERAISING_STATES (taskflow.engines.action_engine.engine.ActionEngine attribute) no_successors_iter() (taskflow.types.graph.DiGraph method) Node (class in taskflow.types.tree)

node_dict_factory (taskflow.types.graph.OrderedDiGraph attribute) (taskflow.types.graph.OrderedGraph attribute) NonBlockingConductor (class in taskflow.conductors.backends.impl_nonblocking) NoOpDecider (class in taskflow.engines.action_engine.deciders) NORMAL (taskflow.jobs.base.JobPriority attribute) normpath() (taskflow.persistence.backends.impl_memory.FakeFilesystem class method) NotFound Notifier (class in taskflow.types.notifier) notifier (taskflow.conductors.base.Conductor property) (taskflow.engines.base.Engine property) (taskflow.task.Task property) Notify (class in taskflow.engines.worker_based.protocol) notify() (taskflow.types.notifier.Notifier method) NotifyingJobBoard (class in taskflow.jobs.base) NotImplementedError

O

on_failure() (taskflow.retry.AlwaysRevert method) (taskflow.retry.AlwaysRevertAll method) (taskflow.retry.ForEach method) (taskflow.retry.ParameterizedForEach method) (taskflow.retry.Retry method) (taskflow.retry.Times method)

options (taskflow.engines.base.Engine property) OrderedDiGraph (class in taskflow.types.graph) OrderedGraph (class in taskflow.types.graph) OrderedSet (class in taskflow.types.sets) outcomes_iter() (taskflow.retry.History method)

P

ParallelActionEngine (class in taskflow.engines.action_engine.engine) ParallelGreenThreadTaskExecutor (class in taskflow.engines.action_engine.executor) ParallelProcessTaskExecutor (class in taskflow.engines.action_engine.process_executor) ParallelTaskExecutor (class in taskflow.engines.action_engine.executor) ParallelThreadTaskExecutor (class in taskflow.engines.action_engine.executor) ParameterizedForEach (class in taskflow.retry) parse_uri() (in module taskflow.utils.misc) path_iter() (taskflow.types.tree.Node method) PathBasedBackend (class in taskflow.persistence.path_based) PathBasedConnection (class in taskflow.persistence.path_based) PatternCompiler (class in taskflow.engines.action_engine.compiler) pformat() (taskflow.exceptions.TaskFlowException method) (taskflow.persistence.backends.impl_memory.FakeFilesystem method) (taskflow.persistence.models.AtomDetail method) (taskflow.persistence.models.FlowDetail method) (taskflow.persistence.models.LogBook method) (taskflow.types.failure.Failure method) (taskflow.types.graph.DiGraph method) (taskflow.types.graph.Graph method) (taskflow.types.tree.Node method) pick_first_not_none() (in module taskflow.utils.misc) pick_widest() (in module taskflow.deciders) post() (taskflow.jobs.base.JobBoard method)

post_execute() (taskflow.atom.Atom method) post_revert() (taskflow.atom.Atom method) pre_execute() (taskflow.atom.Atom method) pre_revert() (taskflow.atom.Atom method) prepare() (taskflow.engines.action_engine.engine.ActionEngine method) (taskflow.engines.base.Engine method) PrintingDurationListener (class in taskflow.listeners.timing) PrintingListener (class in taskflow.listeners.printing) priority (taskflow.atom.Atom attribute) (taskflow.jobs.base.Job property) process_response() (taskflow.engines.worker_based.types.ProxyWorkerFinder method) provided_iter() (taskflow.retry.History method) provides (taskflow.flow.Flow property) ProxyWorkerFinder (class in taskflow.engines.worker_based.types) put() (taskflow.persistence.models.AtomDetail method) (taskflow.persistence.models.RetryDetail method) (taskflow.persistence.models.TaskDetail method) Python Enhancement Proposals PEP 0342 PEP 3134, [1], [2] PEP 3148, [1] PEP 409 PEP 415

R

raise_with_cause() (in module taskflow.exceptions) Reader (class in taskflow.engines.action_engine.process_executor) ReduceFunctorTask (class in taskflow.task) REFRESH_PERIODICITY (taskflow.conductors.backends.impl_executor.ExecutorConductor attribute) register() (taskflow.types.notifier.Notifier method) register_deregister() (in module taskflow.types.notifier) register_entity() (taskflow.jobs.base.JobBoard method) remove() (taskflow.types.tree.Node method) reorder() (taskflow.jobs.base.JobPriority class method) Request (class in taskflow.engines.worker_based.protocol) RequestTimeout requires (taskflow.atom.Atom attribute) (taskflow.flow.Flow property) (taskflow.patterns.graph_flow.Flow property) (taskflow.patterns.linear_flow.Flow property) (taskflow.patterns.unordered_flow.Flow property) reraise() (taskflow.types.failure.Failure method) reraise_if_any() (taskflow.types.failure.Failure static method) RESERVED_KEYS (taskflow.types.notifier.Notifier attribute) reset() (taskflow.engines.action_engine.engine.ActionEngine method) (taskflow.engines.base.Engine method) (taskflow.engines.worker_based.types.ProxyWorkerFinder method) (taskflow.persistence.models.AtomDetail method) (taskflow.persistence.models.RetryDetail method) (taskflow.persistence.models.TaskDetail method) (taskflow.storage.Storage method) (taskflow.types.notifier.Notifier method) (taskflow.types.timing.Timeout method) reset_all() (taskflow.engines.action_engine.runtime.Runtime method) reset_atoms() (taskflow.engines.action_engine.runtime.Runtime method) reset_subgraph() (taskflow.engines.action_engine.runtime.Runtime method) reset_target() (taskflow.patterns.graph_flow.TargetedFlow method) Response (class in taskflow.engines.worker_based.protocol)

RESPONSE_SCHEMA (taskflow.engines.worker_based.protocol.Notify attribute) RestrictedNotifier (class in taskflow.types.notifier) resume() (taskflow.engines.action_engine.completer.Completer method) Retry (class in taskflow.retry) RETRY (taskflow.engines.action_engine.compiler.Compilation attribute) retry (taskflow.flow.Flow property) RETRY (taskflow.listeners.capturing.CaptureListener attribute) (taskflow.retry.Decision attribute) retry_subflow() (taskflow.engines.action_engine.runtime.Runtime method) RetryDetail (class in taskflow.persistence.models) RetryScheduler (class in taskflow.engines.action_engine.scheduler) reverse_enumerate() (in module taskflow.utils.misc) reverse_iter() (taskflow.types.tree.Node method) Revert (class in taskflow.engines.action_engine.completer) REVERT (taskflow.retry.Decision attribute) revert() (taskflow.atom.Atom method) (taskflow.retry.Retry method) (taskflow.task.FunctorTask method) REVERT_ALL (taskflow.retry.Decision attribute) revert_retry() (taskflow.engines.action_engine.executor.SerialRetryExecutor method) revert_task() (taskflow.engines.action_engine.executor.ParallelTaskExecutor method) (taskflow.engines.action_engine.executor.SerialTaskExecutor method) (taskflow.engines.action_engine.executor.TaskExecutor method) RevertAll (class in taskflow.engines.action_engine.completer) RevertAndRetry (class in taskflow.engines.action_engine.completer) root_path (taskflow.persistence.backends.impl_memory.FakeFilesystem attribute) run() (in module taskflow.engines.helpers) (taskflow.conductors.backends.impl_executor.ExecutorConductor method) (taskflow.conductors.base.Conductor method) (taskflow.engines.action_engine.engine.ActionEngine method) (taskflow.engines.base.Engine method) run_iter() (taskflow.engines.action_engine.engine.ActionEngine method) Runtime (class in taskflow.engines.action_engine.runtime)

S

safe_copy_dict() (in module taskflow.utils.misc) save() (taskflow.storage.Storage method) save_factory_details() (in module taskflow.engines.helpers) save_logbook() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) save_retry_failure() (taskflow.storage.Storage method) schedule() (taskflow.engines.action_engine.scheduler.RetryScheduler method) (taskflow.engines.action_engine.scheduler.Scheduler method) (taskflow.engines.action_engine.scheduler.TaskScheduler method) Scheduler (class in taskflow.engines.action_engine.scheduler) SCHEMA (taskflow.engines.worker_based.protocol.Request attribute) (taskflow.engines.worker_based.protocol.Response attribute) (taskflow.types.failure.Failure attribute) schema_validate() (in module taskflow.utils.schema_utils) ScopeWalker (class in taskflow.engines.action_engine.scopes) Selector (class in taskflow.engines.action_engine.selector) SENDER_SCHEMA (taskflow.engines.worker_based.protocol.Notify attribute) sequence_minus() (in module taskflow.utils.misc) SerialActionEngine (class in taskflow.engines.action_engine.engine) SerialRetryExecutor (class in taskflow.engines.action_engine.executor) SerialTaskExecutor (class in taskflow.engines.action_engine.executor) set_atom_intention() (taskflow.storage.Storage method) set_atom_state() (taskflow.storage.Storage method) set_flow_state() (taskflow.storage.Storage method) set_result() (taskflow.engines.worker_based.protocol.Request method) set_target() (taskflow.patterns.graph_flow.TargetedFlow method) set_task_progress() (taskflow.storage.Storage method) split() (taskflow.persistence.backends.impl_memory.FakeFilesystem static method)

start() (taskflow.engines.action_engine.executor.ParallelTaskExecutor method) (taskflow.engines.action_engine.executor.SerialRetryExecutor method) (taskflow.engines.action_engine.executor.SerialTaskExecutor method) (taskflow.engines.action_engine.executor.TaskExecutor method) (taskflow.engines.action_engine.process_executor.ParallelProcessTaskExecutor method) (taskflow.utils.threading_utils.ThreadBundle method) STARTING_PREFIX (taskflow.types.tree.Node attribute) state (taskflow.jobs.base.Job property) (taskflow.persistence.models.AtomDetail attribute) (taskflow.persistence.models.FlowDetail attribute) statistics (taskflow.engines.action_engine.engine.ActionEngine property) (taskflow.engines.base.Engine property) stop() (taskflow.conductors.backends.impl_executor.ExecutorConductor method) (taskflow.engines.action_engine.executor.ParallelTaskExecutor method) (taskflow.engines.action_engine.executor.SerialRetryExecutor method) (taskflow.engines.action_engine.executor.SerialTaskExecutor method) (taskflow.engines.action_engine.executor.TaskExecutor method) (taskflow.engines.action_engine.process_executor.ParallelProcessTaskExecutor method) (taskflow.utils.threading_utils.ThreadBundle method) Storage (class in taskflow.storage) storage (taskflow.engines.action_engine.engine.ActionEngine attribute) (taskflow.engines.base.Engine property) StorageFailure Strategy (class in taskflow.engines.action_engine.completer) StrEnum (class in taskflow.utils.misc) StringIO (class in taskflow.utils.misc) suspend() (taskflow.engines.action_engine.engine.ActionEngine method) (taskflow.engines.base.Engine method) symlink() (taskflow.persistence.backends.impl_memory.FakeFilesystem method)

T

tally() (taskflow.engines.action_engine.deciders.Decider method) (taskflow.engines.action_engine.deciders.IgnoreDecider method) (taskflow.engines.action_engine.deciders.NoOpDecider method) TargetedFlow (class in taskflow.patterns.graph_flow) Task (class in taskflow.task) TASK (taskflow.engines.action_engine.compiler.Compilation attribute) (taskflow.listeners.capturing.CaptureListener attribute) Task/retry arguments Task/retry results TaskCompiler (class in taskflow.engines.action_engine.compiler) TaskDetail (class in taskflow.persistence.models) TaskExecutor (class in taskflow.engines.action_engine.executor) taskflow.atom module taskflow.conductors.backends module taskflow.conductors.backends.impl_blocking module taskflow.conductors.backends.impl_executor module taskflow.conductors.backends.impl_nonblocking module taskflow.conductors.base module taskflow.deciders module taskflow.engines.action_engine.builder module taskflow.engines.action_engine.compiler module taskflow.engines.action_engine.completer module taskflow.engines.action_engine.deciders module taskflow.engines.action_engine.engine module taskflow.engines.action_engine.executor module taskflow.engines.action_engine.process_executor module taskflow.engines.action_engine.runtime module taskflow.engines.action_engine.scheduler module taskflow.engines.action_engine.selector module taskflow.engines.action_engine.traversal module taskflow.engines.base module taskflow.engines.helpers module taskflow.engines.worker_based.endpoint module taskflow.engines.worker_based.protocol module taskflow.engines.worker_based.types module taskflow.exceptions module taskflow.flow module taskflow.formatters module taskflow.jobs.backends module taskflow.jobs.base module taskflow.listeners.base module taskflow.patterns.graph_flow module taskflow.patterns.linear_flow module taskflow.patterns.unordered_flow module

taskflow.persistence.backends module taskflow.persistence.backends.impl_dir module taskflow.persistence.backends.impl_memory module taskflow.persistence.base module taskflow.persistence.models module taskflow.persistence.path_based module taskflow.storage module taskflow.task module taskflow.types.entity module taskflow.types.failure module taskflow.types.graph module taskflow.types.notifier module taskflow.types.sets module taskflow.types.timing module taskflow.types.tree module taskflow.utils.async_utils module taskflow.utils.banner module taskflow.utils.eventlet_utils module taskflow.utils.iter_utils module taskflow.utils.kombu_utils module taskflow.utils.misc module taskflow.utils.persistence_utils module taskflow.utils.schema_utils module taskflow.utils.threading_utils module TaskFlowException TaskScheduler (class in taskflow.engines.action_engine.scheduler) temporary_flow_detail() (in module taskflow.utils.persistence_utils) temporary_log_book() (in module taskflow.utils.persistence_utils) Terminator (class in taskflow.engines.action_engine.compiler) ThreadBundle (class in taskflow.utils.threading_utils) Timeout (class in taskflow.types.timing) Times (class in taskflow.retry) to_dict() (taskflow.engines.worker_based.protocol.Message method) (taskflow.engines.worker_based.protocol.Notify method) (taskflow.engines.worker_based.protocol.Request method) (taskflow.engines.worker_based.protocol.Response method) (taskflow.persistence.models.AtomDetail method) (taskflow.persistence.models.FlowDetail method) (taskflow.persistence.models.LogBook method) (taskflow.persistence.models.RetryDetail method) (taskflow.types.failure.Failure method) to_digraph() (taskflow.types.tree.Node method) TopicWorker (class in taskflow.engines.worker_based.types) topological_sort() (taskflow.types.graph.DiGraph method) total_workers (taskflow.engines.worker_based.types.ProxyWorkerFinder property) traceback_str (taskflow.types.failure.Failure property) transition() (taskflow.engines.worker_based.protocol.Request method) transition_and_log_error() (taskflow.engines.worker_based.protocol.Request method) translate() (taskflow.deciders.Depth class method) trash() (taskflow.jobs.base.JobBoard method) TYPE (taskflow.engines.worker_based.protocol.Notify attribute) (taskflow.engines.worker_based.protocol.Request attribute) (taskflow.engines.worker_based.protocol.Response attribute)

U

UnclaimableJob union() (taskflow.types.sets.OrderedSet method) unique_seen() (in module taskflow.utils.iter_utils) UnknownSender update() (taskflow.persistence.models.AtomDetail method) (taskflow.persistence.models.FlowDetail method) update_atom_details() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) update_atom_metadata() (taskflow.storage.Storage method)

update_flow_details() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) update_flow_metadata() (taskflow.storage.Storage method) update_progress() (taskflow.task.Task method) upgrade() (taskflow.persistence.base.Connection method) (taskflow.persistence.path_based.PathBasedConnection method) uuid (taskflow.jobs.base.Job property) (taskflow.persistence.models.AtomDetail property) (taskflow.persistence.models.FlowDetail property) (taskflow.persistence.models.LogBook property)

V

validate() (taskflow.engines.action_engine.engine.ActionEngine method) (taskflow.engines.base.Engine method) (taskflow.persistence.backends.impl_dir.Connection method) (taskflow.persistence.backends.impl_memory.Connection method) (taskflow.persistence.base.Connection method) (taskflow.types.failure.Failure class method)

value (taskflow.types.timing.Timeout property) VERTICAL_CONN (taskflow.types.tree.Node attribute) VERY_HIGH (taskflow.jobs.base.JobPriority attribute) VERY_LOW (taskflow.jobs.base.JobPriority attribute)

W

wait() (taskflow.conductors.backends.impl_executor.ExecutorConductor method) (taskflow.jobs.base.Job method) (taskflow.jobs.base.JobBoard method) (taskflow.types.timing.Timeout method)

wait_for_workers() (taskflow.engines.worker_based.types.ProxyWorkerFinder method) WAIT_TIMEOUT (taskflow.conductors.backends.impl_executor.ExecutorConductor attribute) (taskflow.engines.action_engine.process_executor.ParallelProcessTaskExecutor attribute) while_is_not() (in module taskflow.utils.iter_utils) WrappedFailure