weaver.processes.wps3_process

Module Contents

weaver.processes.wps3_process.LOGGER[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_PROVIDER = 1[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_PREPARE = 2[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_DEPLOY = 3[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_VISIBLE = 4[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_READY = 5[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_EXECUTION = 9[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_MONITORING = 10[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_FETCH_OUT = 90[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_COMPLETED = 100[source]
class weaver.processes.wps3_process.Wps3Process(step_payload: weaver.typedefs.JSON, joborder: weaver.typedefs.JSON, process: str, request: pywps.app.WPSRequest, update_status: weaver.typedefs.UpdateStatusPartialFunction)[source]

Common interface for WpsProcess to be used in CWL jobs.

resolve_data_source(self, step_payload, joborder)[source]
get_user_auth_header(self)[source]
is_deployed(self)[source]
is_visible(self: Ellipsis)Union[bool, None][source]

Gets the process visibility.

Returns

True/False correspondingly for public/private if visibility is retrievable, False if authorized access but process cannot be found, None if forbidden access.

set_visibility(self, visibility)[source]
describe_process(self)[source]
deploy(self)[source]
prepare(self)[source]
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’}

monitor(self, job_status_uri)[source]
get_job_status(self, job_status_uri, retry=True)[source]
get_job_results(self: str, job_id)List[weaver.typedefs.JSON][source]

Obtains produced output results from successful job status ID.

stage_job_results(self, results, expected_outputs, out_dir)[source]
stage_job_inputs(self, workflow_inputs)[source]