result_container

Container class for results of tasks. A Task can return no, one or more outputs. They are stored inside of an instance of this container class.

class mosaic_orchestrator.result_container.ResultContainer[source]
apply_to_obj(obj: ATask)[source]

Set the same attributes on a Task to restore a Task from the cache

Parameters:

obj (ATask) – Task object

calc_hash(task: ATask) str[source]

Get a new hash of this work product. Needed to check if the inputs have changed

get_return_value() Union[ResultContainer, Any][source]

Get whatever the run() method has returned. If it returned nothing, then return this result container instead.

Returns:

Returned value of run()

Return type:

Union[ResultContainer, Any]

property outputs

Get all outputs in this result container

Yields:

tuple – name, output

update_container(task: ATask, task_outputs: dict, run_return: Any)[source]

Update this result container with the outputs of the task

Parameters:
  • task (ATask) – The corresponding task

  • task_outputs (dict) – Dictionary of outputs

  • run_return (Any) – The return value of the run method