weaver.processes.wps_workflow
Module Contents
- weaver.processes.wps_workflow.default_make_tool(toolpath_object: Ellipsis, loading_context: cwltool.context.LoadingContext, get_job_process_definition: weaver.typedefs.JobProcessDefinitionCallback) cwltool.process.Process [source]
- class weaver.processes.wps_workflow.CallbackJob(job: WpsWorkflow, output_callback: Callable[[Any, Any], Any], cachebuilder: cwltool.builder.Builder, jobcache: Text)[source]
- class weaver.processes.wps_workflow.WpsWorkflow(toolpath_object: Dict[Text, Any], loading_context: cwltool.context.LoadingContext, get_job_process_definition: weaver.typedefs.JobProcessDefinitionCallback)[source]
Definition of a CWL
workflow
that can executeWPS
application packages as intermediate job steps.Steps are expected to be defined as individual
weaver.processes.wps_package.WpsPackage
references.Build a Process object from the provided dictionary.
- job(joborder: Ellipsis, output_callbacks: Callable[[Any, Any], Any], runtime_context: cwltool.context.RuntimeContext) Generator[Union[cwltool.job.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: Ellipsis, 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[weaver.typedefs.CWL_Output_Type])[source]
Initialize the job object.
- run(runtimeContext: Ellipsis, tmpdir_lock: Optional[threading.Lock] = None) None [source]