process#
Attributes#
Classes#
Module Contents#
- process.logger#
- process.client_timeout#
- class process.Process(process_id_with_prefix)#
- inputs: dict#
- outputs: dict#
- process_id_with_prefix#
- id = None#
- title = None#
- version = None#
- job_control_options = None#
- description = None#
- keywords = None#
- metadata = None#
- links = None#
- provider_prefix#
- process_id#
- async load_process_details()#
- validate_exec_body(parameters)#
- is_required(parameter_metadata)#
- check_for_cache(parameters, user_id)#
Checks if the job has already been executed. Returns the job id if it has, None otherwise.
- execute(exec_body, user)#
- async start_process_execution(request_body, user)#
- async _submit_remote_job(session: aiohttp.ClientSession, url: str, request_body: dict, auth: aiohttp.BasicAuth | None) aiohttp.ClientResponse#
- async _create_local_job_instance(remote_job_id: str, name, request_body, user)#
- async _fetch_remote_job_status(session: aiohttp.ClientSession, url, remote_job_id, auth) dict#
- async _extract_remote_job_id(response: aiohttp.ClientResponse) str#
Extracts the remote job ID from the aiohttp response object. Tries the Location header first, then the response body for jobID/jobId.
- _wait_for_results_async(job: ump.api.models.job.Job)#
- async _wait_for_results(job: ump.api.models.job.Job)#
- async _poll_job_until_finished(job, provider_config)#
- _update_job_from_status(job: ump.api.models.job.Job, status_info)#
- _set_job_failed(job: ump.api.models.job.Job, message: str)#
- _set_job_successful(job: ump.api.models.job.Job)#
- async _store_results_if_needed(job: ump.api.models.job.Job)#
- is_finished(job_details)#
- to_dict()#
- to_json()#
- __str__()#
- __repr__()#