Index

A

Async (class in task_processing.runners.async)

AsyncError

C

callback_loop() (task_processing.runners.async.Async method)

cb (task_processing.runners.async.EventHandler attribute) control_event() (in module task_processing.interfaces.event)

D

DefaultTaskConfigInterface (class in task_processing.interfaces.task_executor)

E

Event (class in task_processing.interfaces.event)

event_producer() (task_processing.runners.subscription.Subscription method) EventHandler (class in task_processing.runners.async)

G

get_event_queue() (task_processing.interfaces.task_executor.TaskExecutor method)

J

json_deserializer() (in module task_processing.interfaces.event)

json_serializer() (in module task_processing.interfaces.event)

K

kill() (task_processing.interfaces.runner.Runner method) (task_processing.interfaces.task_executor.TaskExecutor method) (task_processing.runners.async.Async method) (task_processing.runners.promise.Promise method) (task_processing.runners.subscription.Subscription method) (task_processing.runners.sync.Sync method)

P

predicate (task_processing.runners.async.EventHandler attribute)

Promise (class in task_processing.runners.promise)

R

run() (task_processing.interfaces.runner.Runner method) (task_processing.interfaces.task_executor.TaskExecutor method) (task_processing.runners.async.Async method) (task_processing.runners.promise.Promise method) (task_processing.runners.subscription.Subscription method) (task_processing.runners.sync.Sync method)

Runner (class in task_processing.interfaces.runner)

S

stop() (task_processing.interfaces.task_executor.TaskExecutor method) (task_processing.runners.async.Async method) (task_processing.runners.promise.Promise method) (task_processing.runners.subscription.Subscription method) (task_processing.runners.sync.Sync method)

Subscription (class in task_processing.runners.subscription) Sync (class in task_processing.runners.sync)

T

TASK_CONFIG_INTERFACE (task_processing.interfaces.runner.Runner attribute) (task_processing.interfaces.task_executor.TaskExecutor attribute) task_event() (in module task_processing.interfaces.event) task_processing (module) task_processing.interfaces (module) task_processing.interfaces.event (module) task_processing.interfaces.runner (module)

task_processing.interfaces.task_executor (module) task_processing.plugins (module) task_processing.runners (module) task_processing.runners.async (module) task_processing.runners.promise (module) task_processing.runners.subscription (module) task_processing.runners.sync (module) TaskExecutor (class in task_processing.interfaces.task_executor)

V

validate_task_event() (task_processing.interfaces.event.Event static method)