Module Contents

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

Common interface for WpsProcess to be used is cwl jobs

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

abstract execute(self, workflow_inputs: CWL, out_dir: AnyStr, expected_outputs: Dict[AnyStr, AnyStr])[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.

  • 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]
static host_file(file_name)[source]