weaver.processes.wps_workflow

Module Contents

weaver.processes.wps_workflow.LOGGER[source]
weaver.processes.wps_workflow.DEFAULT_TMP_PREFIX = tmp[source]
weaver.processes.wps_workflow.default_make_tool(toolpath_object, loading_context, get_job_process_definition) → ProcessCWL[source]
class weaver.processes.wps_workflow.CallbackJob(job, output_callback, cachebuilder, jobcache)[source]

Bases: object

run(self, loading_context)[source]
class weaver.processes.wps_workflow.WpsWorkflow(toolpath_object, loading_context, get_job_process_definition)[source]

Bases: cwltool.process.Process

job(self, joborder, output_callbacks, runtime_context)[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:

collect_output_ports(self, ports, builder, outdir, compute_checksum=True, jobname='', readers=None)[source]
collect_output(self, schema, builder, outdir, fs_access, compute_checksum=True)[source]
class weaver.processes.wps_workflow.WpsWorkflowJob(builder, joborder, requirements, hints, name, wps_process, expected_outputs)[source]

Bases: cwltool.job.JobBase

run(self, runtimeContext, tmpdir_lock=None)[source]
execute(self, runtime, env, runtime_context)[source]