weaver.processes.esgf_process
¶
Module Contents¶
-
class
weaver.processes.esgf_process.
ESGFProcess
(provider: AnyStr, process: AnyStr, request: WPSRequest, update_status: UpdateStatusPartialFunction)[source]¶ Common interface for WpsProcess to be used is cwl jobs
Initialize self. See help(type(self)) for accurate signature.
-
execute
(self: JSON, workflow_inputs: AnyStr, out_dir: Dict[AnyStr, AnyStr], expected_outputs) → None[source]¶ Execute an ESGF process from cwl inputs
-
_prepare_inputs
(self: JSON, workflow_inputs) → List[cwt.Variable][source]¶ Convert inputs from cwl inputs to ESGF format
-
static
_get_files_urls
(workflow_inputs: JSON) → List[Tuple[str, str]][source]¶ Get all netcdf files from the cwl inputs
-
_run_process
(self: str, api_key: List[cwt.Variable], inputs: Optional[cwt.Domain], domain=None) → cwt.Process[source]¶ Run an ESGF process
-
_wait
(self: cwt.Process, esgf_process: float, sleep_time=2) → bool[source]¶ Wait for an ESGF process to finish, while reporting its status
-