索引

_

__getitem__() （pyflowx.RunReport 方法）

A

add() （pyflowx.Graph 方法） add_subgraph() （pyflowx.Graph 方法） aliases（pyflowx.CliRunner 属性）

all_deps() （pyflowx.Graph 方法） all_specs() （pyflowx.Graph 方法） allow_upstream_skip（pyflowx.TaskSpec 属性） attempts（pyflowx.TaskResult 属性）

B

backoff（pyflowx.RetryPolicy 属性） batch() （pyflowx.JSONBackend 方法）

batch() （pyflowx.StateBackend 方法） build_cli_parser()（在 pyflowx 模块中）

C

cache_key（pyflowx.TaskSpec 属性） chain() （pyflowx.Graph 方法） clear() （pyflowx.JSONBackend 方法） clear() （pyflowx.StateBackend 方法） CliRunner（pyflowx 中的类） cmd（pyflowx.TaskSpec 属性） commands（pyflowx.CliRunner 属性） compose()（在 pyflowx 模块中）

concurrency_key（pyflowx.GraphDefaults 属性） concurrency_key（pyflowx.TaskSpec 属性） conditions（pyflowx.TaskSpec 属性） continue_on_error（pyflowx.GraphDefaults 属性） continue_on_error（pyflowx.TaskSpec 属性） create_parser() （pyflowx.CliRunner 方法） cwd（pyflowx.GraphDefaults 属性） cwd（pyflowx.TaskSpec 属性） CycleError

D

defaults（pyflowx.Graph 属性） defaults（pyflowx.TaskSpec 属性） delay（pyflowx.RetryPolicy 属性） dependencies() （pyflowx.Graph 方法） depends_on（pyflowx.TaskSpec 属性） deps（pyflowx.Graph 属性）

describe() （pyflowx.Graph 方法） describe() （pyflowx.RunReport 方法） description（pyflowx.CliRunner 属性） DuplicateTaskError durations() （pyflowx.RunReport 方法） duration（pyflowx.TaskResult 属性）

E

effective_fn（pyflowx.TaskSpec 属性） env_context() （pyflowx.TaskSpec 方法） env（pyflowx.GraphDefaults 属性）

env（pyflowx.TaskSpec 属性） error（pyflowx.TaskResult 属性） executor（pyflowx.TaskSpec 属性）

F

failed_tasks() （pyflowx.RunReport 方法） FAILED（pyflowx.TaskStatus 属性） finished_at（pyflowx.TaskResult 属性）

flush() （pyflowx.JSONBackend 方法） flush() （pyflowx.StateBackend 方法） fn（pyflowx.TaskSpec 属性）

G

get() （pyflowx.StateBackend 方法） get_fn()（在 pyflowx 模块中）

GraphDefaults（pyflowx 中的类） graphs（pyflowx.CliRunner 属性） Graph（pyflowx 中的类）

H

has() （pyflowx.StateBackend 方法）

has_fn()（在 pyflowx 模块中） hooks（pyflowx.TaskSpec 属性）

I

InjectionError

J

jitter（pyflowx.RetryPolicy 属性）

JSONBackend（pyflowx 中的类）

L

layers() （pyflowx.Graph 方法）

load() （pyflowx.StateBackend 方法） load_yaml()（在 pyflowx 模块中）

M

map() （pyflowx.Graph 方法） max_attempts（pyflowx.RetryPolicy 属性）

MemoryBackend（pyflowx 中的类） MissingDependencyError

N

namespace（pyflowx.Graph 属性）

names（pyflowx.Graph 属性） name（pyflowx.TaskSpec 属性）

O

on_failure（pyflowx.TaskHooks 属性）

P

parse_yaml_string()（在 pyflowx 模块中） PENDING（pyflowx.TaskStatus 属性） post_run（pyflowx.TaskHooks 属性）

pre_run（pyflowx.TaskHooks 属性） priority（pyflowx.GraphDefaults 属性） priority（pyflowx.TaskSpec 属性） PyFlowXError

R

reason（pyflowx.TaskResult 属性） register_fn()（在 pyflowx 模块中） resolved_spec() （pyflowx.Graph 方法） result_of() （pyflowx.RunReport 方法） results（pyflowx.RunReport 属性） retries（pyflowx.RetryPolicy 属性） retry_on（pyflowx.RetryPolicy 属性） RetryPolicy（pyflowx 中的类） retry（pyflowx.GraphDefaults 属性）

retry（pyflowx.TaskSpec 属性） run() （pyflowx.CliRunner 方法） run()（在 pyflowx 模块中） run_cli() （pyflowx.CliRunner 方法） run_cli()（在 pyflowx 模块中） run_command()（在 pyflowx 模块中） run_yaml()（在 pyflowx 模块中） RUNNING（pyflowx.TaskStatus 属性） RunReport（pyflowx 中的类）

S

save() （pyflowx.JSONBackend 方法） save() （pyflowx.StateBackend 方法） should_execute() （pyflowx.TaskSpec 方法） should_retry() （pyflowx.RetryPolicy 方法） skip_if_missing（pyflowx.TaskSpec 属性） skipped_tasks() （pyflowx.RunReport 方法） SKIPPED（pyflowx.TaskStatus 属性） soft_depends_on（pyflowx.TaskSpec 属性） spec() （pyflowx.Graph 方法） specs（pyflowx.Graph 属性） spec（pyflowx.TaskResult 属性） started_at（pyflowx.TaskResult 属性）

StateBackend（pyflowx 中的类） status（pyflowx.TaskResult 属性） storage_key() （pyflowx.TaskSpec 方法） StorageError strategy（pyflowx.CliRunner 属性） strategy（pyflowx.GraphDefaults 属性） strategy（pyflowx.TaskSpec 属性） subgraph() （pyflowx.Graph 方法） subgraph_by_names() （pyflowx.Graph 方法） succeeded_tasks() （pyflowx.RunReport 方法） success（pyflowx.RunReport 属性） SUCCESS（pyflowx.TaskStatus 属性） summary() （pyflowx.RunReport 方法）

T

tags（pyflowx.GraphDefaults 属性） tags（pyflowx.TaskSpec 属性） task_template()（在 pyflowx 模块中） TaskFailedError TaskHooks（pyflowx 中的类） TaskResult（pyflowx 中的类） tasks_by_status() （pyflowx.RunReport 方法）

TaskSpec（pyflowx 中的类） TaskStatus（pyflowx 中的类） tasks（pyflowx.CliRunner 属性） TaskTimeoutError timeout（pyflowx.GraphDefaults 属性） timeout（pyflowx.TaskSpec 属性） to_mermaid() （pyflowx.Graph 方法）

V

validate() （pyflowx.Graph 方法） value（pyflowx.TaskResult 属性）

verbose（pyflowx.CliRunner 属性） verbose（pyflowx.GraphDefaults 属性） verbose（pyflowx.TaskSpec 属性）

W

wait_seconds() （pyflowx.RetryPolicy 方法）