PYME.cluster.taskWorkerHTTP module

class PYME.cluster.taskWorkerHTTP.RecipeTaskError(taskDescr, traceback, exception=None)

Bases: TaskError

extra_template_kwargs(mode='text')

Over-ride in derived classes to provide extra info to templates

format_taskDesc()
html_error_template = '\n<h5>Error in rule: {rule_id} running task: {task_id} on {comp_name}:{pid}</h5>\n\n<h6>taskDescr:</h6>\n<pre style="font-size: 8pt;">{taskDescr}</pre>\n\n<h6>Recipe:</h6>\n{recipe}\n\n<h6>Traceback:</h6>\n<pre style="font-size: 8pt;color: darkred;">{traceback}</pre>\n\n<hrule>\n'
template = '===========================================================================\nError in rule: {rule_id} running task: {task_id} on {comp_name}:{pid}\n\ntaskDescr:\n----------\n{taskDescr}\n\nRecipe:\n-------\n{recipe}\n\nTraceback:\n----------\n{traceback}\n\n'
class PYME.cluster.taskWorkerHTTP.TaskError(taskDescr, traceback, exception=None)

Bases: object

extra_template_kwargs(mode='txt')

Over-ride in derived classes to provide extra info to templates

format_taskDesc()
html_error_template = '\n<h5>Error in rule: {rule_id} running task: {task_id} on {comp_name}:{pid}</h5>\n\n<h6>taskDescr:</h6>\n<pre style="text-size:8pt;">{taskDescr}</pre>\n\n<h6>Traceback:</h6>\n<pre style="text-size:8pt;">{traceback}</pre>\n\n<hrule>\n'
property html_log_url
property log_url
template = '===========================================================================\nError in rule: {rule_id} running task: {task_id} on {comp_name}:{pid}\n\ntaskDescr:\n----------\n{taskDescr}\n\nTraceback:\n----------\n{traceback}\n\n'
to_string(mode='txt')
PYME.cluster.taskWorkerHTTP.on_SIGHUP(signum, frame)
PYME.cluster.taskWorkerHTTP.str_presenter(dumper, data)
class PYME.cluster.taskWorkerHTTP.taskWorker(nodeserver_port)

Bases: object

computeLoop()
loop_forever()
returnLoop()

Loop forever returning task results

Returns
tasksLoop()

Loop forever asking for tasks to queue up for this worker

Returns