weaver.processes.wps_workflow
¶
Module Contents¶
-
weaver.processes.wps_workflow.
default_make_tool
(toolpath_object: weaver.typedefs.ToolPathObjectType, loading_context: cwltool.context.LoadingContext, get_job_process_definition: weaver.typedefs.GetJobProcessDefinitionFunction) → cwltool.process.Process[source]¶
-
class
weaver.processes.wps_workflow.
CallbackJob
(: weaver.processes.wps_workflow.WpsWorkflow, job: Callable[([Any, Any], Any)], output_callback: cwltool.builder.Builder, cachebuilder: Text, jobcache)[source]¶
-
class
weaver.processes.wps_workflow.
WpsWorkflow
(: Dict[(Text, Any)], toolpath_object: cwltool.context.LoadingContext, loading_context: weaver.typedefs.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: cwltool.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: cwltool.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: weaver.processes.wps_process_base.WpsProcessInterface, expected_outputs: List[ExpectedOutputType])[source]¶ Initialize the job object.