TaskRunner

This is used to run a Task. It can be used in unit test to test a Task.

Simply provide the task type, config params and inputs. then you can call the run method to test your task and check outputs

:raises MissingInputResourcesException: [description] :raises Exception: [description] :return: [description] :rtype: [type]

Functions

__init__

Initialize self. See help(type(self)) for accurate signature.

task_type : Type

params : Dict

inputs : Dict

config_model_id : str

input_specs : InputSpecs

output_specs : OutputSpecs

config_specs : ConfigSpecs

task_id : str

scenario_id : str

add_log_observer

Method to create an observer and attached it to the task. The log will be available in the retuned BasicMessageObserver. This can be useful for testings

Return type : BasicMessageObserver

add_observer

Method to create an observer and attached it to the task. The log will be available in the retuned BasicMessageObserver. This can be useful for testings

observer : MessageObserver

check_before_run

This method check the config and inputs and then execute the check before run of the task

Return type : CheckBeforeTaskResult

force_dispatch_waiting_messages

get_output

output_name : str

Return type : Resource

get_outputs

Return type : Dict

get_task

Return type : Task

run

This method, checks the config, inputs and then run the task

Return type : Dict

run_after_task

set_input

input_name : str

resource : Resource

set_progress_bar

progress_bar : ProgressBar

Have you developed a brick?