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_DEPLOY = 2[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_VISIBLE = 3[source]
weaver.processes.wps3_process.REMOTE_JOB_PROGRESS_REQ_PREP = 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, joborder, process, request, update_status)[source]

Bases: weaver.processes.wps_process_base.WpsProcessInterface

resolve_data_source(self, step_payload, joborder)[source]
get_user_auth_header(self)[source]
is_deployed(self)[source]
is_visible(self)[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]
execute(self, workflow_inputs, out_dir, expected_outputs)[source]
get_job_status(self, job_status_uri, retry=True)[source]
get_job_results(self, job_id)[source]