weaver.processes.wps_process_base

Module Contents

class weaver.processes.wps_process_base.WpsProcessInterface(request)[source]

Common interface for WpsProcess to be used in CWL jobs.

abstract execute(self: Ellipsis, workflow_inputs: weaver.typedefs.CWL_RuntimeInputsMap, out_dir: str, expected_outputs: Dict[str, str])None[source]

Execute a remote process using the given inputs.

The function is expected to monitor the process and update the status. Retrieve the expected outputs and store them in the out_dir.

Parameters
  • workflow_inputsCWL job dict

  • out_dir – directory where the outputs must be written

  • expected_outputs – expected value outputs as {‘id’: ‘value’}

make_request(self, method, url, retry, status_code_mock=None, **kwargs)[source]
host_file(self, file_name)[source]