weaver.processes.wps_workflow

Module Contents

weaver.processes.wps_workflow.LOGGER

weaver.processes.wps_workflow.DEFAULT_TMP_PREFIX = tmp

weaver.processes.wps_workflow.default_make_tool(toolpath_object: ToolPathObjectType, loading_context: LoadingContext, get_job_process_definition: GetJobProcessDefinitionFunction) → ProcessCWL

class weaver.processes.wps_workflow.CallbackJob(: WpsWorkflow, job: Callable[[Any, Any], Any], output_callback: Builder, cachebuilder: Text, jobcache)

Initialize self. See help(type(self)) for accurate signature.

run(self: RuntimeContext, loading_context)

class weaver.processes.wps_workflow.WpsWorkflow(: Dict[Text, Any], toolpath_object: LoadingContext, loading_context: GetJobProcessDefinitionFunction, get_job_process_definition)

Build a Process object from the provided dictionary.

job(self, joborder: Dict[Text, AnyValue], output_callbacks: Callable[[Any, Any], Any], runtime_context: RuntimeContext)

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

collect_output_ports(self, ports: Set[Dict[Text, Any]], builder: Builder, outdir: Text, compute_checksum: bool = True, jobname: Text = '', readers: Dict[Text, Any] = None)

collect_output(self, schema: Dict[Text, Any], builder: Builder, outdir: Text, fs_access: StdFsAccess, compute_checksum: bool = True)

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])

Initialize the job object.

run(self, runtimeContext: RuntimeContext, tmpdir_lock: Optional[threading.Lock] = None)

execute(self: List[Text], runtime: MutableMapping[Text, Text], env: RuntimeContext, runtime_context)