Index

_

__init__() (conveyor.context.ContextManager method) (conveyor.context.PipelineContext method) (conveyor.error_handling.LoggingErrorHandler method) (conveyor.error_handling.RetryConfig method) (conveyor.pipeline.Pipeline method) (conveyor.stream.AsyncStream method) (conveyor.tasks.BaseTask method) (conveyor.tasks.BatchTask method) (conveyor.tasks.SingleTask method)

A

add() (conveyor.pipeline.Pipeline method) as_completed() (conveyor.pipeline.Pipeline method) (conveyor.stream.AsyncStream method) (conveyor.tasks.BaseTask method)

AsyncStream (class in conveyor.stream)

B

backoff_multiplier (conveyor.error_handling.RetryConfig attribute) base_delay (conveyor.error_handling.RetryConfig attribute)

BaseTask (class in conveyor.tasks) batch_task() (in module conveyor.decorators) BatchTask (class in conveyor.tasks)

C

collect() (conveyor.stream.AsyncStream method) ContextManager (class in conveyor.context) conveyor.context module conveyor.decorators module conveyor.error_handling module

conveyor.pipeline module conveyor.stream module conveyor.tasks module copy() (conveyor.context.PipelineContext method)

D

data (conveyor.context.PipelineContext attribute)

E

ErrorHandler (class in conveyor.error_handling)

execution_mode (conveyor.context.PipelineContext attribute) exponential_backoff (conveyor.error_handling.RetryConfig attribute)

G

get_context() (conveyor.tasks.BaseTask method)

get_current_context() (in module conveyor.context)

H

handle_error() (conveyor.error_handling.ErrorHandler method) (conveyor.error_handling.LoggingErrorHandler method)

L

LoggingErrorHandler (class in conveyor.error_handling)

M

max_attempts (conveyor.error_handling.RetryConfig attribute) max_delay (conveyor.error_handling.RetryConfig attribute) max_parallelism (conveyor.context.PipelineContext attribute) module conveyor.context conveyor.decorators conveyor.error_handling conveyor.pipeline conveyor.stream conveyor.tasks

P

Pipeline (class in conveyor.pipeline) pipeline_id (conveyor.context.PipelineContext attribute) PipelineContext (class in conveyor.context)

process() (conveyor.tasks.BaseTask method) (conveyor.tasks.BatchTask method) (conveyor.tasks.SingleTask method)

R

RetryConfig (class in conveyor.error_handling)

S

set_current_context() (in module conveyor.context)

single_task() (in module conveyor.decorators) SingleTask (class in conveyor.tasks)

W

with_context() (conveyor.pipeline.Pipeline method) (in module conveyor.context)

with_execution_mode() (conveyor.pipeline.Pipeline method) with_inputs() (conveyor.tasks.BatchTask method) (conveyor.tasks.SingleTask method)