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)[source]¶ Execute an ESGF process from cwl inputs
-
_run_process
(self: str, api_key: List[cwt.Variable], inputs: Optional[cwt.Domain], domain=None)[source]¶ Run an ESGF process
-
_wait
(self: cwt.Process, esgf_process: float, sleep_time=2)[source]¶ Wait for an ESGF process to finish, while reporting its status
-