索引

_

__call__() (taskflow.types.notifier.Listener 方法)

__iter__() (taskflow.engines.action_engine.scopes.ScopeWalker 方法)

A

abandon() (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.JobBoard 方法) ActionEngine (taskflow.engines.action_engine.engine 中的类) add() (taskflow.flow.Flow 方法) (taskflow.patterns.graph_flow.Flow 方法) (taskflow.patterns.graph_flow.TargetedFlow 方法) (taskflow.patterns.linear_flow.Flow 方法) (taskflow.patterns.unordered_flow.Flow 方法) (taskflow.persistence.models.FlowDetail 方法) (taskflow.persistence.models.LogBook 方法) (taskflow.types.tree.Node 方法) add_edge() (taskflow.types.graph.DiGraph 方法) (taskflow.types.graph.Graph 方法) add_node() (taskflow.types.graph.DiGraph 方法) (taskflow.types.graph.Graph 方法) adjlist_inner_dict_factory (taskflow.types.graph.OrderedDiGraph 属性) (taskflow.types.graph.OrderedGraph 属性) adjlist_outer_dict_factory (taskflow.types.graph.OrderedDiGraph 属性) (taskflow.types.graph.OrderedGraph 属性)

affect() (taskflow.engines.action_engine.deciders.Decider 方法) (taskflow.engines.action_engine.deciders.IgnoreDecider 方法) (taskflow.engines.action_engine.deciders.NoOpDecider 方法) ALL (taskflow.deciders.Depth 属性) AlwaysRevert (taskflow.retry 中的类) AlwaysRevertAll (taskflow.retry 中的类) AmbiguousDependency ANY (taskflow.types.notifier.Notifier 属性) apply() (taskflow.engines.action_engine.completer.Revert 方法) (taskflow.engines.action_engine.completer.RevertAll 方法) (taskflow.engines.action_engine.completer.RevertAndRetry 方法) (taskflow.engines.action_engine.completer.Strategy 方法) apply_expiry() (taskflow.utils.redis_utils 模块中) args (taskflow.types.notifier.Listener 属性) as_int() (taskflow.utils.misc 模块中) Atom (taskflow.atom 中的类) ATOM (taskflow.deciders.Depth 属性) atom_notifier (taskflow.engines.base.Engine 属性) AtomDetail (taskflow.persistence.models 中的类)

B

Backend (taskflow.persistence.base 中的类) backend (taskflow.persistence.backends.impl_sqlalchemy.Connection 属性) (taskflow.persistence.base.Connection 属性) (taskflow.persistence.path_based.PathBasedConnection 属性) (taskflow.storage.Storage 属性) backend() (taskflow.jobs.backends 模块中) (taskflow.persistence.backends 模块中) BACKWARD (taskflow.engines.action_engine.traversal.Direction 属性) banner (taskflow.engines.worker_based.worker.Worker 属性) BASE_EXCEPTIONS (taskflow.types.failure.Failure 属性) bfs_iter() (taskflow.types.tree.Node 方法) bfs_predecessors_iter() (taskflow.types.graph.DiGraph 方法)

binary_decode() (taskflow.utils.misc 模块中) binary_encode() (taskflow.utils.misc 模块中) bind() (taskflow.utils.threading_utils.ThreadBundle 方法) BlockingConductor (taskflow.conductors.backends.impl_blocking 中的类) board (taskflow.jobs.base.Job 属性) (taskflow.jobs.base.JobBoardIterator 属性) book (taskflow.jobs.base.Job 属性) book_name (taskflow.jobs.base.Job 属性) book_uuid (taskflow.jobs.base.Job 属性) breadth_first_iterate() (taskflow.engines.action_engine.traversal 模块中) build() (taskflow.engines.action_engine.builder.MachineBuilder 方法) build_a_machine() (taskflow.engines.worker_based.protocol 模块中) BytesIO (taskflow.utils.misc 中的类)

C

cachedproperty (taskflow.utils.misc 中的类) callback (taskflow.types.notifier.Listener 属性) can_be_registered() (taskflow.types.notifier.Notifier 方法) (taskflow.types.notifier.RestrictedNotifier 方法) can_trigger_notification() (taskflow.types.notifier.Notifier 方法) cancel_futures() (taskflow.engines.action_engine.builder.MachineMemory 方法) capture_failure() (taskflow.utils.misc 模块中) CaptureListener (taskflow.listeners.capturing 中的类) caused_by() (taskflow.retry.History 方法) causes (taskflow.types.failure.Failure 属性) change_flow_state() (taskflow.storage.Storage 方法) check() (taskflow.exceptions.WrappedFailure 方法) (taskflow.types.failure.Failure 方法) check_and_affect() (taskflow.engines.action_engine.deciders.Decider 方法) check_atom_transition() (taskflow.engines.action_engine.runtime.Runtime 方法) check_compatible() (taskflow.utils.kazoo_utils 模块中) check_for_eventlet() (taskflow.utils.eventlet_utils 模块中) checked_commit() (taskflow.utils.kazoo_utils 模块中) CheckingClaimListener (taskflow.listeners.claims 中的类) child_count() (taskflow.types.tree.Node 方法) claim() (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.JobBoard 方法) clamp() (taskflow.utils.misc 模块中) clean() (taskflow.engines.worker_based.types.ProxyWorkerFinder 方法) cleanup_retry_history() (taskflow.storage.Storage 方法) clear() (taskflow.persistence.backends.impl_memory.FakeFilesystem 方法) clear_all() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) CLIENT_CONF_TRANSFERS (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) close() (taskflow.conductors.base.Conductor 方法) (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.JobBoard 方法) (taskflow.persistence.backends.impl_dir.DirBackend 方法) (taskflow.persistence.backends.impl_memory.MemoryBackend 方法) (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.backends.impl_sqlalchemy.SQLAlchemyBackend 方法) (taskflow.persistence.backends.impl_zookeeper.ZkBackend 方法) (taskflow.persistence.base.Backend 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) Compilation (taskflow.engines.action_engine.compiler 中的类) compilation (taskflow.engines.action_engine.engine.ActionEngine 属性)

CompilationFailure compile() (taskflow.engines.action_engine.compiler.FlowCompiler 方法) (taskflow.engines.action_engine.compiler.PatternCompiler 方法) (taskflow.engines.action_engine.engine.ActionEngine 方法) (taskflow.engines.action_engine.runtime.Runtime 方法) (taskflow.engines.base.Engine 方法) complete() (taskflow.engines.action_engine.completer.Completer 方法) complete_failure() (taskflow.engines.action_engine.completer.Completer 方法) Completer (taskflow.engines.action_engine.completer 中的类) Conductor (taskflow.conductors.base 中的类) conductor (taskflow.conductors.base.Conductor 属性) ConductorFailure connect() (taskflow.conductors.base.Conductor 方法) (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.JobBoard 方法) connected (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 属性) (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) (taskflow.jobs.base.JobBoard 属性) Connection (taskflow.persistence.backends.impl_dir 中的类) (taskflow.persistence.backends.impl_memory 中的类) (taskflow.persistence.backends.impl_sqlalchemy 中的类) (taskflow.persistence.base 中的类) connection_details (taskflow.engines.worker_based.proxy.Proxy 属性) constructor_options (taskflow.engines.action_engine.executor.ParallelTaskExecutor 属性) consume() (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.JobBoard 方法) convert_to_timeout() (taskflow.types.timing 模块中) copy() (taskflow.persistence.models.AtomDetail 方法) (taskflow.persistence.models.FlowDetail 方法) (taskflow.persistence.models.LogBook 方法) (taskflow.persistence.models.RetryDetail 方法) (taskflow.persistence.models.TaskDetail 方法) (taskflow.task.Task 方法) (taskflow.types.failure.Failure 方法) (taskflow.types.sets.OrderedSet 方法) count() (taskflow.utils.iter_utils 模块中) countdown_iter() (taskflow.utils.misc 模块中) create_flow_detail() (taskflow.utils.persistence_utils 模块中) created_on (taskflow.jobs.backends.impl_etcd.EtcdJob 属性) (taskflow.jobs.backends.impl_redis.RedisJob 属性) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJob 属性) (taskflow.jobs.base.Job 属性) current_state (taskflow.engines.worker_based.protocol.Request 属性)

D

daemon_thread() (taskflow.utils.threading_utils 模块中) Decider (taskflow.engines.action_engine.deciders 中的类) Decision (taskflow.retry 中的类) decode_json() (taskflow.utils.misc 模块中) decode_msgpack() (taskflow.utils.misc 模块中) DEFAULT_FILE_ENCODING (taskflow.persistence.backends.impl_dir.DirBackend 属性) DEFAULT_LISTEN_FOR (taskflow.listeners.base 模块中) DEFAULT_NAMESPACE (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) DEFAULT_PATH (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) (taskflow.persistence.backends.impl_memory.MemoryBackend 属性) (taskflow.persistence.backends.impl_zookeeper.ZkBackend 属性) (taskflow.persistence.path_based.PathBasedBackend 属性) DEFAULT_RETRY_OPTIONS (taskflow.engines.worker_based.proxy.Proxy 属性) DEFAULT_WORKERS (taskflow.engines.action_engine.executor.ParallelGreenThreadTaskExecutor 属性) DelayedPretty (taskflow.utils.kombu_utils 中的类) delete() (taskflow.persistence.backends.impl_memory.FakeFilesystem 方法) DependencyFailure Depth (taskflow.deciders 中的类) depth_first_iterate() (taskflow.engines.action_engine.traversal 模块中) depth_first_reverse_iterate() (taskflow.engines.action_engine.traversal 模块中) deregister() (taskflow.types.notifier.Notifier 方法)

deregister_event() (taskflow.types.notifier.Notifier 方法) destroy_logbook() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) details (taskflow.jobs.base.Job 属性) details_filter (taskflow.types.notifier.Listener 属性) dfs_iter() (taskflow.types.tree.Node 方法) difference() (taskflow.types.sets.OrderedSet 方法) DiGraph (taskflow.types.graph 中的类) DirBackend (taskflow.persistence.backends.impl_dir 中的类) Direction (taskflow.engines.action_engine.traversal 中的类) disallow_when_frozen() (taskflow.utils.misc 模块中) DisallowedAccess disassociate() (taskflow.types.tree.Node 方法) dispatcher (taskflow.engines.worker_based.proxy.Proxy 属性) dispatching (taskflow.conductors.backends.impl_executor.ExecutorConductor 属性) DOES_NOT_EXPIRE (taskflow.utils.redis_utils.UnknownExpire 属性) DumpingListener (taskflow.listeners.base 中的类) Duplicate DurationListener (taskflow.listeners.timing 中的类) DynamicLoggingListener (taskflow.listeners.logging 中的类)

E

edge_attr_dict_factory (taskflow.types.graph.OrderedDiGraph 属性) (taskflow.types.graph.OrderedGraph 属性) Empty empty() (taskflow.types.tree.Node 方法) EMPTY_SPACE_SEP (taskflow.types.tree.Node 属性) Endpoint (taskflow.engines.worker_based.endpoint 中的类) Engine (taskflow.engines.base 中的类) ensure_atom() (taskflow.storage.Storage 方法) ensure_atoms() (taskflow.storage.Storage 方法) ensure_path() (taskflow.persistence.backends.impl_memory.FakeFilesystem 方法) Entity (taskflow.types.entity 中的类) ENTITY_FOLDER (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) ENTITY_KIND (taskflow.conductors.base.Conductor 属性) entity_path (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) EtcdJob (taskflow.jobs.backends.impl_etcd 中的类) EtcdJobBoard (taskflow.jobs.backends.impl_etcd 中的类) EVENTS_EMITTED (taskflow.conductors.backends.impl_executor.ExecutorConductor 属性) events_iter() (taskflow.types.notifier.RestrictedNotifier 方法) EventTimeListener (taskflow.listeners.timing 中的类) exc_info (taskflow.types.failure.Failure 属性) exception (taskflow.types.failure.Failure 属性) exception_args (taskflow.types.failure.Failure 属性) exception_str (taskflow.types.failure.Failure 属性) execute() (taskflow.atom.Atom 方法) (taskflow.retry.AlwaysRevert 方法) (taskflow.retry.AlwaysRevertAll 方法) (taskflow.retry.ForEach 方法) (taskflow.retry.ParameterizedForEach 方法) (taskflow.retry.Retry 方法) (taskflow.retry.Times 方法) (taskflow.task.FunctorTask 方法) (taskflow.task.MapFunctorTask 方法) (taskflow.task.ReduceFunctorTask 方法)

execute_retry() (taskflow.engines.action_engine.executor.SerialRetryExecutor 方法) execute_task() (taskflow.engines.action_engine.executor.ParallelTaskExecutor 方法) (taskflow.engines.action_engine.executor.SerialTaskExecutor 方法) (taskflow.engines.action_engine.executor.TaskExecutor 方法) (taskflow.engines.worker_based.executor.WorkerTaskExecutor 方法) execution_graph (taskflow.engines.action_engine.compiler.Compilation 属性) ExecutionFailure ExecutorConductor (taskflow.conductors.backends.impl_executor 中的类) expired (taskflow.engines.worker_based.protocol.Request 属性) expires_in() (taskflow.jobs.backends.impl_etcd.EtcdJob 方法) (taskflow.jobs.backends.impl_redis.RedisJob 方法) export_to_dot() (taskflow.types.graph.DiGraph 方法) (taskflow.types.graph.Graph 方法) extend_expiry() (taskflow.jobs.backends.impl_etcd.EtcdJob 方法) (taskflow.jobs.backends.impl_redis.RedisJob 方法) extract_driver_and_conf() (taskflow.utils.misc 模块中)

F

Failure (taskflow.types.failure 中的类) failure (taskflow.retry.History 属性) failure_to_dict() (taskflow.engines.worker_based.protocol 模块中) FailureFormatter (taskflow.formatters 中的类) FakeFilesystem (taskflow.persistence.backends.impl_memory 中的类) FakeInode (taskflow.persistence.backends.impl_memory 中的类) fetch() (taskflow.conductors.backends 模块中) (taskflow.jobs.backends 模块中) (taskflow.persistence.backends 模块中) (taskflow.storage.Storage 方法) fetch_action() (taskflow.engines.action_engine.runtime.Runtime 方法) fetch_all() (taskflow.storage.Storage 方法) fetch_edge_deciders() (taskflow.engines.action_engine.runtime.Runtime 方法) fetch_mapped_args() (taskflow.storage.Storage 方法) fetch_scheduler() (taskflow.engines.action_engine.runtime.Runtime 方法) fetch_scopes_for() (taskflow.engines.action_engine.runtime.Runtime 方法) fetch_unsatisfied_args() (taskflow.storage.Storage 方法) fill() (taskflow.utils.iter_utils 模块中) finalize_client() (taskflow.utils.kazoo_utils 模块中) find() (taskflow.persistence.models.FlowDetail 方法) (taskflow.persistence.models.LogBook 方法) (taskflow.types.tree.Node 方法) find_first_match() (taskflow.utils.iter_utils 模块中) (taskflow.types.tree.Node 方法) find_owner() (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.JobBoard 方法) find_retry() (taskflow.engines.action_engine.runtime.Runtime 方法) find_subclasses() (taskflow.utils.misc 模块中) FINISH_STATES (taskflow.listeners.base 模块中) fix_newlines() (taskflow.utils.misc 模块中)

Flow (taskflow.flow 中的类) (taskflow.patterns.graph_flow 中的类) (taskflow.patterns.linear_flow 中的类) (taskflow.patterns.unordered_flow 中的类) FLOW (taskflow.deciders.Depth 属性) (taskflow.engines.action_engine.compiler.Compilation 属性) flow (taskflow.engines.action_engine.compiler.Terminator 属性) FLOW (taskflow.listeners.capturing.CaptureListener 属性) FLOW_END (taskflow.engines.action_engine.compiler.Compilation 属性) flow_from_detail() (taskflow.engines.helpers 模块中) flow_meta (taskflow.storage.Storage 属性) flow_name (taskflow.storage.Storage 属性) flow_uuid (taskflow.storage.Storage 属性) FlowCompiler (taskflow.engines.action_engine.compiler 中的类) FlowDetail (taskflow.persistence.models 中的类) ForEach (taskflow.retry 中的类) format() (taskflow.formatters.FailureFormatter 方法) FORWARD (taskflow.engines.action_engine.traversal.Direction 属性) freeze() (taskflow.types.graph.DiGraph 方法) (taskflow.types.graph.Graph 方法) fresh_copy() (taskflow.types.graph.DiGraph 方法) (taskflow.types.graph.Graph 方法) (taskflow.types.graph.OrderedDiGraph 方法) (taskflow.types.graph.OrderedGraph 方法) from_dict() (taskflow.engines.worker_based.protocol.Request 静态方法) (taskflow.persistence.models.AtomDetail 类方法) (taskflow.persistence.models.FlowDetail 类方法) (taskflow.persistence.models.LogBook 类方法) (taskflow.persistence.models.RetryDetail 类方法) (taskflow.types.failure.Failure 类方法) from_exception() (taskflow.types.failure.Failure 类方法) FrozenNode FunctorTask (taskflow.task 中的类)

G

generate_delays() (taskflow.utils.iter_utils 模块中) get() (taskflow.persistence.backends.impl_memory.FakeFilesystem 方法) (taskflow.storage.Storage 方法) get_atom_details() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) get_atom_intention() (taskflow.storage.Storage 方法) get_atom_state() (taskflow.storage.Storage 方法) get_atom_uuid() (taskflow.storage.Storage 方法) get_atoms_for_flow() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) get_atoms_states() (taskflow.storage.Storage 方法) get_connection() (taskflow.persistence.backends.impl_dir.DirBackend 方法) (taskflow.persistence.backends.impl_memory.MemoryBackend 方法) (taskflow.persistence.backends.impl_sqlalchemy.SQLAlchemyBackend 方法) (taskflow.persistence.backends.impl_zookeeper.ZkBackend 方法) (taskflow.persistence.base.Backend 方法) get_edge_data() (taskflow.types.graph.DiGraph 方法) get_execute_failures() (taskflow.storage.Storage 方法) get_execute_result() (taskflow.storage.Storage 方法) get_expiry() (taskflow.utils.redis_utils 模块中) get_failures() (taskflow.storage.Storage 方法) get_flow_details() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法)

get_flow_state() (taskflow.storage.Storage 方法) get_flows_for_book() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) get_hostname() (taskflow.utils.misc 模块中) get_ident() (taskflow.utils.threading_utils 模块中) get_logbook() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) get_logbooks() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) get_optimal_thread_count() (taskflow.utils.threading_utils 模块中) get_retry_histories() (taskflow.storage.Storage 方法) get_retry_history() (taskflow.storage.Storage 方法) get_revert_failures() (taskflow.storage.Storage 方法) get_revert_result() (taskflow.storage.Storage 方法) get_task_progress() (taskflow.storage.Storage 方法) get_task_progress_details() (taskflow.storage.Storage 方法) get_version_string() (taskflow.utils.misc 模块中) get_worker_for_task() (taskflow.engines.worker_based.types.ProxyWorkerFinder 方法) Graph (taskflow.types.graph 中的类)

H

Handler (taskflow.engines.worker_based.dispatcher 中的类) has_failures() (taskflow.storage.Storage 方法) hierarchy (taskflow.engines.action_engine.compiler.Compilation 属性)

HIGH (taskflow.jobs.base.JobPriority 属性) History (taskflow.retry 中的类) HORIZONTAL_CONN (taskflow.types.tree.Node 属性)

I

IGNORABLE_STATES (taskflow.engines.action_engine.engine.ActionEngine 属性) IgnoreDecider (taskflow.engines.action_engine.deciders 中的类) IncompatibleVersion incr() (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) index() (taskflow.types.tree.Node 方法) inject() (taskflow.storage.Storage 方法) inject_atom_args() (taskflow.storage.Storage 方法) injector_name (taskflow.storage.Storage 属性) interrupt() (taskflow.types.timing.Timeout 方法) intersection() (taskflow.types.sets.OrderedSet 方法) InvalidFormat InvalidState is_alive() (taskflow.utils.threading_utils 模块中) is_directed_acyclic() (taskflow.types.graph.DiGraph 方法) is_equivalent() (taskflow.types.notifier.Listener 方法) is_iterable() (taskflow.utils.misc 模块中) is_registered() (taskflow.types.notifier.Notifier 方法) is_running (taskflow.engines.worker_based.proxy.Proxy 属性) is_server_new_enough() (taskflow.utils.redis_utils 模块中)

is_stopped() (taskflow.types.timing.Timeout 方法) is_success() (taskflow.engines.action_engine.runtime.Runtime 方法) issubset() (taskflow.types.sets.OrderedSet 方法) issuperset() (taskflow.types.sets.OrderedSet 方法) iter_forever() (taskflow.utils.iter_utils 模块中) iter_links() (taskflow.flow.Flow 方法) (taskflow.patterns.graph_flow.Flow 方法) (taskflow.patterns.linear_flow.Flow 方法) (taskflow.patterns.unordered_flow.Flow 方法) iter_next_atoms() (taskflow.engines.action_engine.selector.Selector 方法) iter_nodes() (taskflow.flow.Flow 方法) (taskflow.patterns.graph_flow.Flow 方法) (taskflow.patterns.linear_flow.Flow 方法) (taskflow.patterns.unordered_flow.Flow 方法) iterate_nodes() (taskflow.engines.action_engine.runtime.Runtime 方法) iterate_retries() (taskflow.engines.action_engine.runtime.Runtime 方法) iterjobs() (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.JobBoard 方法)

J

Job (taskflow.jobs.base 中的类) job_count (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 属性) (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) (taskflow.jobs.base.JobBoard 属性) JOB_PREFIX (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性)

JobBoard (taskflow.jobs.base 中的类) JobBoardIterator (taskflow.jobs.base 中的类) JobFailure JobPriority (taskflow.jobs.base 中的类) join() (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.persistence.backends.impl_memory.FakeFilesystem 静态方法)

K

KazooTransactionException key (taskflow.jobs.backends.impl_redis.RedisJob 属性)

KEY_NOT_FOUND (taskflow.utils.redis_utils.UnknownExpire 属性) KEY_PIECE_SEP (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) kwargs (taskflow.types.notifier.Listener 属性)

L

last_failures (taskflow.persistence.models.RetryDetail 属性) last_modified (taskflow.jobs.backends.impl_etcd.EtcdJob 属性) (taskflow.jobs.backends.impl_redis.RedisJob 属性) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJob 属性) (taskflow.jobs.base.Job 属性) last_modified_key (taskflow.jobs.backends.impl_redis.RedisJob 属性) LAST_MODIFIED_POSTFIX (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) last_results (taskflow.persistence.models.AtomDetail 属性) (taskflow.persistence.models.RetryDetail 属性) LINE_SEP (taskflow.types.tree.Node 属性) link() (taskflow.patterns.graph_flow.Flow 方法) (taskflow.patterns.graph_flow.TargetedFlow 方法) Listener (taskflow.listeners.base 中的类) (taskflow.types.notifier 中的类)

listeners_iter() (taskflow.types.notifier.Notifier 方法) listings_key (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) load() (taskflow.engines.helpers 模块中) load_from_detail() (taskflow.engines.helpers 模块中) load_from_factory() (taskflow.engines.helpers 模块中) lock (taskflow.storage.Storage 属性) lock_path (taskflow.jobs.backends.impl_zookeeper.ZookeeperJob 属性) LOCK_POSTFIX (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) LOG (taskflow.conductors.backends.impl_executor.ExecutorConductor 属性) LogBook (taskflow.persistence.models 中的类) LoggingListener (taskflow.listeners.logging 中的类) LOW (taskflow.jobs.base.JobPriority 属性) ls() (taskflow.persistence.backends.impl_memory.FakeFilesystem 方法) ls_r() (taskflow.persistence.backends.impl_memory.FakeFilesystem 方法)

M

MachineBuilder (taskflow.engines.action_engine.builder 中的类) MachineMemory (taskflow.engines.action_engine.builder 中的类) make_an_event() (taskflow.engines.worker_based.protocol 模块中) make_banner() (taskflow.utils.banner 模块中) make_client() (taskflow.utils.kazoo_utils 模块中) make_completed_future() (taskflow.utils.async_utils 模块中) MapFunctorTask (taskflow.task 中的类) match_type() (taskflow.utils.misc 模块中) matches() (taskflow.types.failure.Failure 方法) MAX_MACHINE_STATES_RETAINED (taskflow.engines.action_engine.engine.ActionEngine 属性) MAX_SIMULTANEOUS_JOBS (taskflow.conductors.backends.impl_blocking.BlockingConductor 属性) (taskflow.conductors.backends.impl_executor.ExecutorConductor 属性) (taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor 属性) maybe_publish() (taskflow.engines.worker_based.types.ProxyWorkerFinder 方法) MemoryBackend (taskflow.persistence.backends.impl_memory 中的类) merge() (taskflow.persistence.models.AtomDetail 方法) (taskflow.persistence.models.FlowDetail 方法) (taskflow.persistence.models.LogBook 方法) (taskflow.persistence.models.RetryDetail 方法) (taskflow.persistence.models.TaskDetail 方法) merge_graphs() (taskflow.types.graph 模块中) merge_uri() (taskflow.utils.misc 模块中) Message (taskflow.engines.worker_based.protocol 中的类) MESSAGE_TPL (taskflow.exceptions.MissingDependencies 属性) messages_processed (taskflow.engines.worker_based.types.ProxyWorkerFinder 属性) millis_to_datetime() (taskflow.utils.misc 模块中) MIN_REDIS_VERSION (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) MIN_ZK_VERSION (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) MissingDependencies 模块 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.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.dispatcher taskflow.engines.worker_based.endpoint taskflow.engines.worker_based.engine taskflow.engines.worker_based.executor taskflow.engines.worker_based.protocol taskflow.engines.worker_based.proxy taskflow.engines.worker_based.types taskflow.engines.worker_based.worker taskflow.exceptions taskflow.flow taskflow.formatters taskflow.jobs.backends taskflow.jobs.backends.impl_etcd taskflow.jobs.backends.impl_redis taskflow.jobs.backends.impl_zookeeper 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.backends.impl_sqlalchemy taskflow.persistence.backends.impl_zookeeper 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.kazoo_utils taskflow.utils.kombu_utils taskflow.utils.misc taskflow.utils.persistence_utils taskflow.utils.redis_utils taskflow.utils.schema_utils taskflow.utils.threading_utils

MultipleChoices

N

name (taskflow.engines.action_engine.compiler.Terminator 属性) (taskflow.flow.Flow 属性) (taskflow.jobs.base.Job 属性) (taskflow.jobs.base.JobBoard 属性) (taskflow.persistence.models.AtomDetail 属性) (taskflow.persistence.models.FlowDetail 属性) (taskflow.persistence.models.LogBook 属性) namespace (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) NAMESPACE_SEP (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) NEIGHBORS (taskflow.deciders.Depth 属性) NO_CONSUME_EXCEPTIONS (taskflow.conductors.backends.impl_executor.ExecutorConductor 属性) NO_FETCH_STATES (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) no_op() (taskflow.utils.threading_utils 模块中) no_predecessors_iter() (taskflow.types.graph.DiGraph 方法) NO_RERAISING_STATES (taskflow.engines.action_engine.engine.ActionEngine 属性) no_successors_iter() (taskflow.types.graph.DiGraph 方法)

Node (taskflow.types.tree 中的类) node_dict_factory (taskflow.types.graph.OrderedDiGraph 属性) (taskflow.types.graph.OrderedGraph 属性) NonBlockingConductor (taskflow.conductors.backends.impl_nonblocking 中的类) NoOpDecider (taskflow.engines.action_engine.deciders 中的类) NORMAL (taskflow.jobs.base.JobPriority 属性) normpath() (taskflow.persistence.backends.impl_memory.FakeFilesystem 类方法) NotFound Notifier (taskflow.types.notifier 中的类) notifier (taskflow.conductors.base.Conductor 属性) (taskflow.engines.base.Engine 属性) (taskflow.task.Task 属性) Notify (taskflow.engines.worker_based.protocol 中的类) notify() (taskflow.types.notifier.Notifier 方法) NotifyingJobBoard (taskflow.jobs.base 中的类) NotImplementedError

O

on_failure() (taskflow.retry.AlwaysRevert 方法) (taskflow.retry.AlwaysRevertAll 方法) (taskflow.retry.ForEach 方法) (taskflow.retry.ParameterizedForEach 方法) (taskflow.retry.Retry 方法) (taskflow.retry.Times 方法) on_message() (taskflow.engines.worker_based.dispatcher.TypeDispatcher 方法)

options (taskflow.engines.base.Engine 属性) OrderedDiGraph (taskflow.types.graph 中的类) OrderedGraph (taskflow.types.graph 中的类) OrderedSet (taskflow.types.sets 中的类) outcomes_iter() (taskflow.retry.History 方法) OWNED_POSTFIX (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) owner_key (taskflow.jobs.backends.impl_redis.RedisJob 属性)

P

ParallelActionEngine (taskflow.engines.action_engine.engine 中的类) ParallelGreenThreadTaskExecutor (taskflow.engines.action_engine.executor 中的类) ParallelTaskExecutor (taskflow.engines.action_engine.executor 中的类) ParallelThreadTaskExecutor (taskflow.engines.action_engine.executor 中的类) ParameterizedForEach (taskflow.retry 中的类) parse_uri() (taskflow.utils.misc 模块中) path (taskflow.jobs.backends.impl_zookeeper.ZookeeperJob 属性) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) path_iter() (taskflow.types.tree.Node 方法) PathBasedBackend (taskflow.persistence.path_based 中的类) PathBasedConnection (taskflow.persistence.path_based 中的类) PatternCompiler (taskflow.engines.action_engine.compiler 中的类) pformat() (taskflow.exceptions.TaskFlowException 方法) (taskflow.persistence.backends.impl_memory.FakeFilesystem 方法) (taskflow.persistence.models.AtomDetail 方法) (taskflow.persistence.models.FlowDetail 方法) (taskflow.persistence.models.LogBook 方法) (taskflow.types.failure.Failure 方法) (taskflow.types.graph.DiGraph 方法) (taskflow.types.graph.Graph 方法) (taskflow.types.tree.Node 方法) pick_first_not_none() (taskflow.utils.misc 模块中) pick_widest() (taskflow.deciders 模块中) post() (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.JobBoard 方法) post_execute() (taskflow.atom.Atom 方法) post_revert() (taskflow.atom.Atom 方法)

pre_execute() (taskflow.atom.Atom 方法) pre_revert() (taskflow.atom.Atom 方法) prepare() (taskflow.engines.action_engine.engine.ActionEngine 方法) (taskflow.engines.base.Engine 方法) prettify_failures() (taskflow.utils.kazoo_utils 模块中) PrintingDurationListener (taskflow.listeners.timing 中的类) PrintingListener (taskflow.listeners.printing 中的类) priority (taskflow.atom.Atom 属性) (taskflow.jobs.backends.impl_etcd.EtcdJob 属性) (taskflow.jobs.backends.impl_redis.RedisJob 属性) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJob 属性) (taskflow.jobs.base.Job 属性) process_message (taskflow.engines.worker_based.dispatcher.Handler 属性) process_response() (taskflow.engines.worker_based.types.ProxyWorkerFinder 方法) provided_iter() (taskflow.retry.History 方法) provides (taskflow.flow.Flow 属性) Proxy (taskflow.engines.worker_based.proxy 中的类) ProxyWorkerFinder (taskflow.engines.worker_based.types 中的类) publish() (taskflow.engines.worker_based.proxy.Proxy 方法) pubsub() (taskflow.utils.redis_utils.RedisClient 方法) put() (taskflow.persistence.models.AtomDetail 方法) (taskflow.persistence.models.RetryDetail 方法) (taskflow.persistence.models.TaskDetail 方法) Python 增强提案 PEP 0342 PEP 3134, [1], [2] PEP 3148, [1] PEP 409 PEP 415

R

raise_with_cause() (taskflow.exceptions 模块中) RedisClient (taskflow.utils.redis_utils 中的类) RedisJob (taskflow.jobs.backends.impl_redis 中的类) RedisJobBoard (taskflow.jobs.backends.impl_redis 中的类) ReduceFunctorTask (taskflow.task 中的类) REFRESH_PERIODICITY (taskflow.conductors.backends.impl_executor.ExecutorConductor 属性) register() (taskflow.types.notifier.Notifier 方法) register_deregister() (taskflow.types.notifier 模块中) register_entity() (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.JobBoard 方法) remove() (taskflow.types.tree.Node 方法) reorder() (taskflow.jobs.base.JobPriority 类方法) Request (taskflow.engines.worker_based.protocol 中的类) RequestTimeout requeue_filters (taskflow.engines.worker_based.dispatcher.TypeDispatcher 属性) requires (taskflow.atom.Atom 属性) (taskflow.flow.Flow 属性) (taskflow.patterns.graph_flow.Flow 属性) (taskflow.patterns.linear_flow.Flow 属性) (taskflow.patterns.unordered_flow.Flow 属性) reraise() (taskflow.types.failure.Failure 方法) reraise_if_any() (taskflow.types.failure.Failure 静态方法) RESERVED_KEYS (taskflow.types.notifier.Notifier 属性) reset() (taskflow.engines.action_engine.engine.ActionEngine 方法) (taskflow.engines.base.Engine 方法) (taskflow.engines.worker_based.types.ProxyWorkerFinder 方法) (taskflow.persistence.models.AtomDetail 方法) (taskflow.persistence.models.RetryDetail 方法) (taskflow.persistence.models.TaskDetail 方法) (taskflow.storage.Storage 方法) (taskflow.types.notifier.Notifier 方法) (taskflow.types.timing.Timeout 方法) reset_all() (taskflow.engines.action_engine.runtime.Runtime 方法) reset_atoms() (taskflow.engines.action_engine.runtime.Runtime 方法) reset_subgraph() (taskflow.engines.action_engine.runtime.Runtime 方法)

reset_target() (taskflow.patterns.graph_flow.TargetedFlow 方法) Response (taskflow.engines.worker_based.protocol 中的类) RESPONSE_SCHEMA (taskflow.engines.worker_based.protocol.Notify 属性) RestrictedNotifier (taskflow.types.notifier 中的类) resume() (taskflow.engines.action_engine.completer.Completer 方法) Retry (taskflow.retry 中的类) RETRY (taskflow.engines.action_engine.compiler.Compilation 属性) retry (taskflow.flow.Flow 属性) RETRY (taskflow.listeners.capturing.CaptureListener 属性) (taskflow.retry.Decision 属性) retry_subflow() (taskflow.engines.action_engine.runtime.Runtime 方法) RetryDetail (taskflow.persistence.models 中的类) RetryScheduler (taskflow.engines.action_engine.scheduler 中的类) reverse_enumerate() (taskflow.utils.misc 模块中) reverse_iter() (taskflow.types.tree.Node 方法) Revert (taskflow.engines.action_engine.completer 中的类) REVERT (taskflow.retry.Decision 属性) revert() (taskflow.atom.Atom 方法) (taskflow.retry.Retry 方法) (taskflow.task.FunctorTask 方法) REVERT_ALL (taskflow.retry.Decision 属性) revert_retry() (taskflow.engines.action_engine.executor.SerialRetryExecutor 方法) revert_task() (taskflow.engines.action_engine.executor.ParallelTaskExecutor 方法) (taskflow.engines.action_engine.executor.SerialTaskExecutor 方法) (taskflow.engines.action_engine.executor.TaskExecutor 方法) (taskflow.engines.worker_based.executor.WorkerTaskExecutor 方法) RevertAll (taskflow.engines.action_engine.completer 中的类) RevertAndRetry (taskflow.engines.action_engine.completer 中的类) root (taskflow.jobs.backends.impl_zookeeper.ZookeeperJob 属性) root_path (taskflow.persistence.backends.impl_memory.FakeFilesystem 属性) run() (taskflow.engines.helpers 模块中) (taskflow.conductors.backends.impl_executor.ExecutorConductor 方法) (taskflow.conductors.base.Conductor 方法) (taskflow.engines.action_engine.engine.ActionEngine 方法) (taskflow.engines.base.Engine 方法) (taskflow.engines.worker_based.worker.Worker 方法) run_iter() (taskflow.engines.action_engine.engine.ActionEngine 方法) Runtime (taskflow.engines.action_engine.runtime 中的类)

S

safe_copy_dict() (taskflow.utils.misc 模块中) save() (taskflow.storage.Storage 方法) save_factory_details() (taskflow.engines.helpers 模块中) save_logbook() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) save_retry_failure() (taskflow.storage.Storage 方法) schedule() (taskflow.engines.action_engine.scheduler.RetryScheduler 方法) (taskflow.engines.action_engine.scheduler.Scheduler 方法) (taskflow.engines.action_engine.scheduler.TaskScheduler 方法) Scheduler (taskflow.engines.action_engine.scheduler 中的类) SCHEMA (taskflow.engines.worker_based.protocol.Request 属性) (taskflow.engines.worker_based.protocol.Response 属性) (taskflow.types.failure.Failure 属性) schema_validate() (taskflow.utils.schema_utils 模块中) ScopeWalker (taskflow.engines.action_engine.scopes 中的类) SCRIPT_ALREADY_CLAIMED (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) SCRIPT_NOT_EXPECTED_OWNER (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) SCRIPT_STATUS_ERROR (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) SCRIPT_STATUS_OK (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) SCRIPT_TEMPLATES (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) SCRIPT_UNKNOWN_JOB (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) SCRIPT_UNKNOWN_OWNER (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) Selector (taskflow.engines.action_engine.selector 中的类) SENDER_SCHEMA (taskflow.engines.worker_based.protocol.Notify 属性) sequence (taskflow.jobs.backends.impl_redis.RedisJob 属性) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJob 属性) sequence_key (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) sequence_minus() (taskflow.utils.misc 模块中) SerialActionEngine (taskflow.engines.action_engine.engine 中的类) SerialRetryExecutor (taskflow.engines.action_engine.executor 中的类) SerialTaskExecutor (taskflow.engines.action_engine.executor 中的类) set_atom_intention() (taskflow.storage.Storage 方法) set_atom_state() (taskflow.storage.Storage 方法) set_flow_state() (taskflow.storage.Storage 方法) set_result() (taskflow.engines.worker_based.protocol.Request 方法) set_target() (taskflow.patterns.graph_flow.TargetedFlow 方法) set_task_progress() (taskflow.storage.Storage 方法)

split() (taskflow.persistence.backends.impl_memory.FakeFilesystem 静态方法) SQLAlchemyBackend (taskflow.persistence.backends.impl_sqlalchemy 中的类) start() (taskflow.engines.action_engine.executor.ParallelTaskExecutor 方法) (taskflow.engines.action_engine.executor.SerialRetryExecutor 方法) (taskflow.engines.action_engine.executor.SerialTaskExecutor 方法) (taskflow.engines.action_engine.executor.TaskExecutor 方法) (taskflow.engines.worker_based.executor.WorkerTaskExecutor 方法) (taskflow.engines.worker_based.proxy.Proxy 方法) (taskflow.utils.threading_utils.ThreadBundle 方法) STARTING_PREFIX (taskflow.types.tree.Node 属性) state (taskflow.jobs.backends.impl_etcd.EtcdJob 属性) (taskflow.jobs.backends.impl_redis.RedisJob 属性) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJob 属性) (taskflow.jobs.base.Job 属性) (taskflow.persistence.models.AtomDetail 属性) (taskflow.persistence.models.FlowDetail 属性) STATE_HISTORY_LENGTH (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) statistics (taskflow.engines.action_engine.engine.ActionEngine 属性) (taskflow.engines.base.Engine 属性) stop() (taskflow.conductors.backends.impl_executor.ExecutorConductor 方法) (taskflow.conductors.base.Conductor 方法) (taskflow.engines.action_engine.executor.ParallelTaskExecutor 方法) (taskflow.engines.action_engine.executor.SerialRetryExecutor 方法) (taskflow.engines.action_engine.executor.SerialTaskExecutor 方法) (taskflow.engines.action_engine.executor.TaskExecutor 方法) (taskflow.engines.worker_based.executor.WorkerTaskExecutor 方法) (taskflow.engines.worker_based.proxy.Proxy 方法) (taskflow.engines.worker_based.worker.Worker 方法) (taskflow.utils.threading_utils.ThreadBundle 方法) Storage (taskflow.storage 中的类) storage (taskflow.engines.action_engine.engine.ActionEngine 属性) (taskflow.engines.base.Engine 属性) StorageFailure Strategy (taskflow.engines.action_engine.completer 中的类) StrEnum (taskflow.utils.misc 中的类) StringIO (taskflow.utils.misc 中的类) suspend() (taskflow.engines.action_engine.engine.ActionEngine 方法) (taskflow.engines.base.Engine 方法) symlink() (taskflow.persistence.backends.impl_memory.FakeFilesystem 方法)

T

tally() (taskflow.engines.action_engine.deciders.Decider 方法) (taskflow.engines.action_engine.deciders.IgnoreDecider 方法) (taskflow.engines.action_engine.deciders.NoOpDecider 方法) TargetedFlow (taskflow.patterns.graph_flow 中的类) Task (taskflow.task 中的类) TASK (taskflow.engines.action_engine.compiler.Compilation 属性) (taskflow.listeners.capturing.CaptureListener 属性) 任务/重试参数 任务/重试结果 TaskCompiler (taskflow.engines.action_engine.compiler 中的类) TaskDetail (taskflow.persistence.models 中的类) TaskExecutor (taskflow.engines.action_engine.executor 中的类) 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.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.dispatcher 模块 taskflow.engines.worker_based.endpoint 模块 taskflow.engines.worker_based.engine 模块 taskflow.engines.worker_based.executor 模块 taskflow.engines.worker_based.protocol 模块 taskflow.engines.worker_based.proxy 模块 taskflow.engines.worker_based.types 模块 taskflow.engines.worker_based.worker 模块 taskflow.exceptions 模块 taskflow.flow 模块 taskflow.formatters 模块 taskflow.jobs.backends 模块 taskflow.jobs.backends.impl_etcd 模块 taskflow.jobs.backends.impl_redis 模块 taskflow.jobs.backends.impl_zookeeper 模块 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.backends.impl_sqlalchemy 模块 taskflow.persistence.backends.impl_zookeeper 模块 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.kazoo_utils 模块 taskflow.utils.kombu_utils 模块 taskflow.utils.misc 模块 taskflow.utils.persistence_utils 模块 taskflow.utils.redis_utils 模块 taskflow.utils.schema_utils 模块 taskflow.utils.threading_utils 模块 TaskFlowException TaskScheduler (taskflow.engines.action_engine.scheduler 中的类) temporary_flow_detail() (taskflow.utils.persistence_utils 模块中) temporary_log_book() (taskflow.utils.persistence_utils 模块中) Terminator (taskflow.engines.action_engine.compiler 中的类) ThreadBundle (taskflow.utils.threading_utils 中的类) Timeout (taskflow.types.timing 中的类) Times (taskflow.retry 中的类) to_dict() (taskflow.engines.worker_based.protocol.Message 方法) (taskflow.engines.worker_based.protocol.Notify 方法) (taskflow.engines.worker_based.protocol.Request 方法) (taskflow.engines.worker_based.protocol.Response 方法) (taskflow.persistence.models.AtomDetail 方法) (taskflow.persistence.models.FlowDetail 方法) (taskflow.persistence.models.LogBook 方法) (taskflow.persistence.models.RetryDetail 方法) (taskflow.types.failure.Failure 方法) to_digraph() (taskflow.types.tree.Node 方法) TopicWorker (taskflow.engines.worker_based.types 中的类) topological_sort() (taskflow.types.graph.DiGraph 方法) total_workers (taskflow.engines.worker_based.types.ProxyWorkerFinder 属性) traceback_str (taskflow.types.failure.Failure 属性) transaction() (taskflow.utils.redis_utils.RedisClient 方法) transition() (taskflow.engines.worker_based.protocol.Request 方法) transition_and_log_error() (taskflow.engines.worker_based.protocol.Request 方法) translate() (taskflow.deciders.Depth 类方法) trash() (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.JobBoard 方法) TRASH_FOLDER (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) trash_key (taskflow.jobs.backends.impl_redis.RedisJobBoard 属性) trash_path (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 属性) TYPE (taskflow.engines.worker_based.protocol.Notify 属性) (taskflow.engines.worker_based.protocol.Request 属性) (taskflow.engines.worker_based.protocol.Response 属性) type_handlers (taskflow.engines.worker_based.dispatcher.TypeDispatcher 属性) TypeDispatcher (taskflow.engines.worker_based.dispatcher 中的类)

U

UnclaimableJob union() (taskflow.types.sets.OrderedSet 方法) unique_seen() (taskflow.utils.iter_utils 模块中) UnknownExpire (taskflow.utils.redis_utils 中的类) update() (taskflow.persistence.models.AtomDetail 方法) (taskflow.persistence.models.FlowDetail 方法) update_atom_details() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) update_atom_metadata() (taskflow.storage.Storage 方法) update_flow_details() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法)

update_flow_metadata() (taskflow.storage.Storage 方法) update_progress() (taskflow.task.Task 方法) upgrade() (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.persistence.path_based.PathBasedConnection 方法) uuid (taskflow.jobs.base.Job 属性) (taskflow.persistence.models.AtomDetail 属性) (taskflow.persistence.models.FlowDetail 属性) (taskflow.persistence.models.LogBook 属性)

V

validate() (taskflow.engines.action_engine.engine.ActionEngine 方法) (taskflow.engines.base.Engine 方法) (taskflow.persistence.backends.impl_dir.Connection 方法) (taskflow.persistence.backends.impl_memory.Connection 方法) (taskflow.persistence.backends.impl_sqlalchemy.Connection 方法) (taskflow.persistence.backends.impl_zookeeper.ZkConnection 方法) (taskflow.persistence.base.Connection 方法) (taskflow.types.failure.Failure 类方法)

validator (taskflow.engines.worker_based.dispatcher.Handler 属性) value (taskflow.types.timing.Timeout 属性) VERTICAL_CONN (taskflow.types.tree.Node 属性) VERY_HIGH (taskflow.jobs.base.JobPriority 属性) VERY_LOW (taskflow.jobs.base.JobPriority 属性)

W

wait() (taskflow.conductors.backends.impl_executor.ExecutorConductor 方法) (taskflow.conductors.base.Conductor 方法) (taskflow.engines.worker_based.proxy.Proxy 方法) (taskflow.engines.worker_based.worker.Worker 方法) (taskflow.jobs.backends.impl_etcd.EtcdJobBoard 方法) (taskflow.jobs.backends.impl_redis.RedisJobBoard 方法) (taskflow.jobs.backends.impl_zookeeper.ZookeeperJobBoard 方法) (taskflow.jobs.base.Job 方法) (taskflow.jobs.base.JobBoard 方法) (taskflow.types.timing.Timeout 方法)

wait_for_workers() (taskflow.engines.worker_based.executor.WorkerTaskExecutor 方法) (taskflow.engines.worker_based.types.ProxyWorkerFinder 方法) WAIT_TIMEOUT (taskflow.conductors.backends.impl_executor.ExecutorConductor 属性) while_is_not() (taskflow.utils.iter_utils 模块中) Worker (taskflow.engines.worker_based.worker 中的类) WorkerBasedActionEngine (taskflow.engines.worker_based.engine 中的类) WorkerTaskExecutor (taskflow.engines.worker_based.executor 中的类) WrappedFailure

Z

ZkBackend (taskflow.persistence.backends.impl_zookeeper 中的类) ZkConnection (taskflow.persistence.backends.impl_zookeeper 中的类)

ZookeeperJob (taskflow.jobs.backends.impl_zookeeper 中的类) ZookeeperJobBoard (taskflow.jobs.backends.impl_zookeeper 中的类)