Job

Job#

class anomalib.pipelines.components.base.job.Job#

Bases: ABC

A job is an atomic unit of work that can be run in parallel with other jobs.

abstractmethod static collect(results)#

Gather the results returned from run.

This can be used to combine the results from multiple runs or to save/process individual job results.

Parameters:: results (list[Any]) – List of results returned from run.
Returns:: Collated results.
Return type:: Any

abstractmethod run(task_id=None)#

A job is a single unit of work that can be run in parallel with other jobs.

task_id is optional and is only passed when the job is run in parallel.

abstractmethod static save(results)#

Save the gathered results.

This can be used to save the results in a file or a database.

Parameters:: results (Any) – The gathered result returned from gather_results.
Return type:: None