task_processing.runners.subscription.
Subscription
Bases: task_processing.interfaces.runner.Runner
task_processing.interfaces.runner.Runner
event_producer
kill
run
stop