task_processing.runners.subscription module

class task_processing.runners.subscription.Subscription(executor, queue)

Bases: task_processing.interfaces.runner.Runner

event_producer()

kill(task_id)

run(task_config)

stop()