task_processing.runners.promise module

class task_processing.runners.promise.Promise(executor, futures_executor)

Bases: task_processing.interfaces.runner.Runner

kill(task_id)

run(task_config)

Schedules execution of the supplied task

Parameters:task_config – An object satisfying the TASK_CONFIG_INTERFACE Returns:A Future object representing the execution of the task.

stop()