weaver.processes.wps_workflow
¶
Module Contents¶
-
weaver.processes.wps_workflow.
default_make_tool
(toolpath_object: ToolPathObjectType, loading_context: LoadingContext, get_job_process_definition: GetJobProcessDefinitionFunction) → ProcessCWL[source]¶
-
class
weaver.processes.wps_workflow.
CallbackJob
(: WpsWorkflow, job: Callable[[Any, Any], Any], output_callback: Builder, cachebuilder: Text, jobcache)[source]¶ Initialize self. See help(type(self)) for accurate signature.
-
class
weaver.processes.wps_workflow.
WpsWorkflow
(: Dict[Text, Any], toolpath_object: LoadingContext, loading_context: GetJobProcessDefinitionFunction, get_job_process_definition)[source]¶ Build a Process object from the provided dictionary.
-
job
(self, joborder: Dict[Text, AnyValue], output_callbacks: Callable[[Any, Any], Any], runtime_context: RuntimeContext) → Generator[Union[JobBase, CallbackJob], None, None][source]¶ Workflow job generator.
- Parameters
joborder – inputs of the job submission
output_callbacks – method to fetch step outputs and corresponding step details
runtime_context – configs about execution environment
- Returns
-
-
class
weaver.processes.wps_workflow.
WpsWorkflowJob
(builder: Builder, joborder: Dict[Text, Union[Dict[Text, Any], List, Text, None]], requirements: List[Dict[Text, Text]], hints: List[Dict[Text, Text]], name: Text, wps_process: WpsProcessInterface, expected_outputs: List[ExpectedOutputType])[source]¶ Initialize the job object.
-
run
(self, runtimeContext: RuntimeContext, tmpdir_lock: Optional[threading.Lock] = None) → None[source]¶
-