task_processing.interfaces.task_executor module¶

class task_processing.interfaces.task_executor.DefaultTaskConfigInterface¶: Bases: pyrsistent._precord.PRecord

class task_processing.interfaces.task_executor.TaskExecutor¶

Bases: object

The core interface for Task Processing This is the class you want to implement to add a new TaskExecutor

TASK_CONFIG_INTERFACE¶

The interface, specified as a PRecord of objects that you will be passing as task_configs to run

get_event_queue()¶

Get queue of events

Returns:	TBD

kill(task_id)¶

Kill the specified task

Parameters:	task_id (str) – The task that you want to kill

run(task_config)¶

Run the supplied task

Parameters:	task_config – An object satistfying the TASK_CONFIG_INTERFACE

The executor should start running the provided task and return the task id.

Returns str task_id:
	Callers get the id of the task that was run

to check status or kill it later