weaver.processes.wps1_process

Module Contents

weaver.processes.wps1_process.LOGGER[source]
weaver.processes.wps1_process.REMOTE_JOB_PROGRESS_REQ_PREP = 2[source]
weaver.processes.wps1_process.REMOTE_JOB_PROGRESS_EXECUTION = 5[source]
weaver.processes.wps1_process.REMOTE_JOB_PROGRESS_MONITORING = 10[source]
weaver.processes.wps1_process.REMOTE_JOB_PROGRESS_FETCH_OUT = 90[source]
weaver.processes.wps1_process.REMOTE_JOB_PROGRESS_COMPLETED = 100[source]
class weaver.processes.wps1_process.Wps1Process(provider: str, process: str, request: pywps.app.WPSRequest, update_status: weaver.typedefs.UpdateStatusPartialFunction)[source]

Common interface for WpsProcess to be used in CWL jobs.

execute(self, workflow_inputs, out_dir, expected_outputs)[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’}