Skip to main content

worker

Workers for handling task running on pods.

Classes​

ProtocolTaskBatchRun​

class ProtocolTaskBatchRun():

Hook to report dataset statistics before and after protocol run.

Initialise the hook.

Ancestors​

Methods​

on_run_end​

def on_run_end(    self, protocol: _BaseProtocol, context: TaskContext, *args: Any, **kwargs: Any,) ‑> None:

Runs after protocol run to report dataset statistics.

SaveFailedFilesToDatabase​

class SaveFailedFilesToDatabase():

Hook to save failed files to database.

Initialise the hook.

Ancestors​

Methods​

on_resilience_end​

def on_resilience_end(    self, protocol: _BaseProtocol, context: TaskContext, *args: Any, **kwargs: Any,) ‑> None:

Runs after protocol run to save failed files to database.

SaveResultsToDatabase​

class SaveResultsToDatabase():

Hook to save protocol results to database.

Initialise the hook.

Ancestors​

Methods​

on_run_end​

def on_run_end(    self, protocol: _BaseProtocol, context: TaskContext, *args: Any, **kwargs: Any,) ‑> None:

Runs after protocol run to save results to database.