weaver.wps_restapi.processes.processes

Module Contents

weaver.wps_restapi.processes.processes.LOGGER[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_SETUP = 1[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_DESCRIBE = 2[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_GET_INPUTS = 4[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_GET_OUTPUTS = 6[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_EXECUTE_REQUEST = 8[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_EXECUTE_STATUS_LOCATION = 10[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_EXECUTE_MONITOR_START = 20[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_EXECUTE_MONITOR_LOOP = 30[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_EXECUTE_MONITOR_ERROR = 80[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_EXECUTE_MONITOR_END = 90[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_NOTIFY = 95[source]
weaver.wps_restapi.processes.processes.JOB_PROGRESS_DONE = 100[source]
weaver.wps_restapi.processes.processes.execute_process(self, job_id, url, headers=None, notification_email=None)[source]
weaver.wps_restapi.processes.processes.make_results_relative(results, settings) → List[JSON][source]

Redefines job results to be saved in database as relative paths to output directory configured in PyWPS (i.e.: relative to weaver.wps_output_dir).

This allows us to easily adjust the exposed result HTTP path according to server configuration (i.e.: relative to weaver.wps_output_path and/or weaver.wps_output_url) and it also avoid rewriting the whole database job results if the setting is changed later on.

weaver.wps_restapi.processes.processes.set_wps_language(wps, accept_language=None, request=None) → None[source]

Set the language property on the WebProcessingService object.

Given the Accept-Language header value, match the best language to the supported languages.

By default, and if no match is found, the WebProcessingService.language property is set to None.

https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Accept-Language (q-factor weighting is ignored, only order is considered)

Parameters:
  • wps – process for which to set the language header if it is accepted
  • accept_language (str) – the value of the Accept-Language header
  • request – request from which to extract Accept-Language header if not provided directly
weaver.wps_restapi.processes.processes.validate_supported_submit_job_handler_parameters(json_body)[source]

Tests supported parameters not automatically validated by colander deserialize.

weaver.wps_restapi.processes.processes.submit_job_handler(request, service_url, is_workflow=False, visibility=None) → HTTPSuccessful[source]
weaver.wps_restapi.processes.processes.submit_provider_job(request)[source]

Execute a provider process.

weaver.wps_restapi.processes.processes.list_remote_processes(service, request) → List[ProcessDB][source]

Obtains a list of remote service processes in a compatible weaver.datatype.Process format.

Note: remote processes won’t be stored to the local process storage.

weaver.wps_restapi.processes.processes.get_provider_processes(request)[source]

Retrieve available provider processes (GetCapabilities).

weaver.wps_restapi.processes.processes.describe_provider_process(request) → ProcessDB[source]

Obtains a remote service process description in a compatible local process format.

Note: this processes won’t be stored to the local process storage.

weaver.wps_restapi.processes.processes.get_provider_process(request)[source]

Retrieve a process description (DescribeProcess).

weaver.wps_restapi.processes.processes.get_processes_filtered_by_valid_schemas(request) → Tuple[List[JSON], List[AnyStr]][source]

Validates the processes summary schemas and returns them into valid/invalid lists. :returns: list of valid process summaries and invalid processes IDs for manual cleanup.

weaver.wps_restapi.processes.processes.get_processes(request)[source]

List registered processes (GetCapabilities). Optionally list both local and provider processes.

weaver.wps_restapi.processes.processes.add_local_process(request)[source]

Register a local process.

weaver.wps_restapi.processes.processes.get_process(request) → ProcessDB[source]
weaver.wps_restapi.processes.processes.get_local_process(request)[source]

Get a registered local process information (DescribeProcess).

weaver.wps_restapi.processes.processes.get_local_process_package(request)[source]

Get a registered local process package definition.

weaver.wps_restapi.processes.processes.get_local_process_payload(request)[source]

Get a registered local process payload definition.

weaver.wps_restapi.processes.processes.get_process_visibility(request)[source]

Get the visibility of a registered local process.

weaver.wps_restapi.processes.processes.set_process_visibility(request)[source]

Set the visibility of a registered local process.

weaver.wps_restapi.processes.processes.delete_local_process(request)[source]

Unregister a local process.

weaver.wps_restapi.processes.processes.submit_local_job(request)[source]

Execute a local process.