task_processing.runners.async module

class task_processing.runners.async.Async(executor, callbacks=None)

Bases: task_processing.interfaces.runner.Runner

callback_loop()

kill(task_id)

run(task_config)

stop()

exception task_processing.runners.async.AsyncError

Bases: Exception

class task_processing.runners.async.EventHandler(predicate, cb)

Bases: tuple

cb

Alias for field number 1

predicate

Alias for field number 0