Index

A

aenter_context() (in module flowsaber.core.base)

AsyncChannel (class in flowsaber.core.channel)

B

BaseTask (class in flowsaber.core.task) BashTask (class in flowsaber.tasks.shell)

Branch (class in flowsaber.core.operators) branch() (flowsaber.core.channel.ChannelBase method)

C

Cache (class in flowsaber.core.utility.cache) cache() (flowsaber.core.context.FlowSaberContext property) Cached (class in flowsaber.core.utility.state) CacheInvalidError call_initialize() (flowsaber.core.base.Component method) (flowsaber.core.flow.Flow method) call_run() (flowsaber.core.task.RunTask method) (flowsaber.core.task.Task method) call_state_change_handlers() (in module flowsaber.core.engine.runner) Cancelled (class in flowsaber.core.utility.state) Cancelling (class in flowsaber.core.utility.state) catch_to_failure() (in module flowsaber.core.engine.runner) Channel (class in flowsaber.core.channel) ChannelBase (class in flowsaber.core.channel) check_run_data() (flowsaber.core.task.RunTask method) clean() (flowsaber.core.task.Task method)

Collect (class in flowsaber.core.operators) collect() (flowsaber.core.channel.ChannelBase method) command() (flowsaber.tasks.shell.ShellTask method) CommandTaskComposeError Component (class in flowsaber.core.base) Component.State (class in flowsaber.core.base) ComponentCallError ComponentExecuteError Concat (class in flowsaber.core.operators) concat() (flowsaber.core.channel.ChannelBase method) config() (flowsaber.core.base.Component property) Constant (class in flowsaber.core.operators) ConstantChannel (class in flowsaber.core.channel) ConstantQueue (class in flowsaber.core.channel) Consumer (class in flowsaber.core.channel) Count (class in flowsaber.core.operators) create_run_data() (flowsaber.core.task.RunTask method)

D

DaskExecutor (class in flowsaber.core.utility.executor) Distinct (class in flowsaber.core.operators)

distinct() (flowsaber.core.channel.ChannelBase method) Done (class in flowsaber.core.utility.state) Drop (class in flowsaber.core.utility.state)

E

Edge (class in flowsaber.core.task) End (class in flowsaber.core.utility.target) enqueue_res() (flowsaber.core.task.BaseTask method) enter_context() (in module flowsaber.core.base)

EventChannel (class in flowsaber.core.channel) EventChannelCheckError execute_command() (flowsaber.tasks.shell.BashTask method) Executor (class in flowsaber.core.utility.executor) executor() (flowsaber.core.context.FlowSaberContext property)

F

Failure (class in flowsaber.core.utility.state) Fetcher (class in flowsaber.core.channel) File (class in flowsaber.core.utility.target) Filter (class in flowsaber.core.operators) filter() (flowsaber.core.channel.ChannelBase method) First (class in flowsaber.core.operators) first() (flowsaber.core.channel.ChannelBase method) Flatten (class in flowsaber.core.operators) flatten() (flowsaber.core.channel.ChannelBase method) Flow (class in flowsaber.core.flow) FlowRunner (class in flowsaber.core.engine.flow_runner) flowsaber.cli (module) flowsaber.core.base (module) flowsaber.core.channel (module) flowsaber.core.context (module)

flowsaber.core.engine.flow_runner (module) flowsaber.core.engine.runner (module) flowsaber.core.engine.task_runner (module) flowsaber.core.flow (module) flowsaber.core.operators (module) flowsaber.core.task (module) flowsaber.core.utility.cache (module) flowsaber.core.utility.executor (module) flowsaber.core.utility.state (module) flowsaber.core.utility.target (module) flowsaber.server.database.models (module) flowsaber.tasks.shell (module) FlowSaberContext (class in flowsaber.core.context) Folder (class in flowsaber.core.utility.target) from_list() (flowsaber.core.channel.ChannelBase class method)

G

Get (class in flowsaber.core.operators) get() (flowsaber.core.channel.ChannelBase method) get_full_name() (flowsaber.core.base.Component method) get_publish_dirs() (flowsaber.tasks.shell.BashTask static method) GetContext (class in flowsaber.core.task)

GetItem (class in flowsaber.core.operators) getitem() (flowsaber.core.channel.ChannelBase method) glob_output_files() (flowsaber.tasks.shell.BashTask class method) Group (class in flowsaber.core.operators) group() (flowsaber.core.channel.ChannelBase method)

H

handle_consumer() (flowsaber.core.operators.Branch method) (flowsaber.core.operators.Collect method) (flowsaber.core.operators.Concat method) (flowsaber.core.operators.Mix method) (flowsaber.core.operators.Sample method) (flowsaber.core.operators.Subscribe method) (flowsaber.core.task.BaseTask method) (flowsaber.core.task.RunTask method) handle_input() (flowsaber.core.operators.Filter method) (flowsaber.core.operators.Flatten method) (flowsaber.core.operators.GetItem method) (flowsaber.core.operators.Group method) (flowsaber.core.operators.Last method) (flowsaber.core.operators.Map method) (flowsaber.core.operators.Reduce method) (flowsaber.core.operators.Take method) (flowsaber.core.operators.Until method) (flowsaber.core.task.BaseTask method)

handle_res() (flowsaber.core.task.Task method) handle_run_data() (flowsaber.core.task.RunTask method) handle_state_change() (flowsaber.core.engine.runner.Runner method)

I

initialize_context() (flowsaber.core.base.Component method) (flowsaber.core.flow.Flow method) (flowsaber.core.operators.Operator method) (flowsaber.core.task.BaseTask method) (flowsaber.core.task.RunTask method) (flowsaber.core.task.Task method)

initialize_input() (flowsaber.core.task.BaseTask method) initialize_output() (flowsaber.core.operators.Constant method) (flowsaber.core.task.BaseTask method) inject_context_attrs() (in module flowsaber.core.context)

J

join() (flowsaber.core.engine.runner.RunnerExecutor method)

L

Last (class in flowsaber.core.operators) last() (flowsaber.core.channel.ChannelBase method) LazyAsyncQueue (class in flowsaber.core.channel)

Local (class in flowsaber.core.utility.executor) LocalCache (class in flowsaber.core.utility.cache) lock() (flowsaber.core.context.FlowSaberContext method) logger() (flowsaber.core.context.FlowSaberContext property)

M

main_loop() (flowsaber.core.engine.runner.RunnerExecutor method) Map (class in flowsaber.core.operators) map() (flowsaber.core.channel.ChannelBase method) Max (class in flowsaber.core.operators)

Merge (class in flowsaber.core.operators) merge() (flowsaber.core.channel.ChannelBase method) Min (class in flowsaber.core.operators) Mix (class in flowsaber.core.operators) mix() (flowsaber.core.channel.ChannelBase method)

N

need_skip() (flowsaber.core.task.Task method)

O

Operator (class in flowsaber.core.operators)

P

Pending (class in flowsaber.core.utility.state)

persist() (flowsaber.core.utility.cache.LocalCache method)

R

Reduce (class in flowsaber.core.operators) reduce() (flowsaber.core.channel.ChannelBase method) Retrying (class in flowsaber.core.utility.state) run() (flowsaber.core.engine.runner.RunnerExecutor method) (flowsaber.core.task.GetContext method) (flowsaber.core.task.RunTask method) (flowsaber.core.utility.executor.DaskExecutor method) (flowsaber.tasks.shell.BashTask method) (flowsaber.tasks.shell.ShellTask method) run_task_timeout() (flowsaber.core.engine.task_runner.TaskRunner method)

run_timeout_signal() (in module flowsaber.core.engine.runner) run_timeout_thread() (in module flowsaber.core.engine.runner) RunDataFileNotFoundError RunDataTypeError RunException Runner (class in flowsaber.core.engine.runner) RunnerExecuteError RunnerExecutor (class in flowsaber.core.engine.runner) RunnerExecutor.DoneException Running (class in flowsaber.core.utility.state) RunTask (class in flowsaber.core.task)

S

Sample (class in flowsaber.core.operators) sample() (flowsaber.core.channel.ChannelBase method) Scheduled (class in flowsaber.core.utility.state) Select (class in flowsaber.core.operators) select() (flowsaber.core.channel.ChannelBase method) send_logs() (flowsaber.core.engine.runner.Runner method) ShellTask (class in flowsaber.tasks.shell) ShellTaskExecuteError Skip (class in flowsaber.core.utility.state) skip() (flowsaber.core.task.Task method) Split (class in flowsaber.core.operators)

split() (flowsaber.core.channel.ChannelBase method) start() (flowsaber.core.base.Component method) (flowsaber.core.engine.runner.RunnerExecutor method) start_execute() (flowsaber.core.flow.Flow method) State (class in flowsaber.core.utility.state) Stdin (class in flowsaber.core.utility.target) Stdout (class in flowsaber.core.utility.target) Subscribe (class in flowsaber.core.operators) subscribe() (flowsaber.core.channel.ChannelBase method) Success (class in flowsaber.core.utility.state) Sum (class in flowsaber.core.operators)

T

Take (class in flowsaber.core.operators) take() (flowsaber.core.channel.ChannelBase method) Target (class in flowsaber.core.utility.target) Task (class in flowsaber.core.task)

task_hash() (flowsaber.core.task.Task property) (flowsaber.tasks.shell.ShellTask property) task_workdir() (flowsaber.core.task.Task property) TaskRunner (class in flowsaber.core.engine.task_runner)

U

Unique (class in flowsaber.core.operators) unique() (flowsaber.core.channel.ChannelBase method)

Until (class in flowsaber.core.operators) until() (flowsaber.core.channel.ChannelBase method) update_run_state() (flowsaber.core.engine.runner.Runner method)

V

value() (flowsaber.core.channel.ChannelBase class method) values() (flowsaber.core.channel.ChannelBase class method)

var (in module flowsaber.core.operators) View (class in flowsaber.core.operators) view() (flowsaber.core.channel.ChannelBase method)