:mod:`weaver.processes.wps_workflow`
====================================

.. py:module:: weaver.processes.wps_workflow


Module Contents
---------------

.. data:: LOGGER
   

   

.. data:: DEFAULT_TMP_PREFIX
   :annotation: = tmp

   

.. function:: default_make_tool(toolpath_object, loading_context, get_job_process_definition) -> ProcessCWL


.. py:class:: CallbackJob(job, output_callback, cachebuilder, jobcache)

   Bases: :class:`object`

   
   .. method:: run(self, loading_context)




.. py:class:: WpsWorkflow(toolpath_object, loading_context, get_job_process_definition)

   Bases: :class:`cwltool.process.Process`

   
   .. method:: job(self, joborder, output_callbacks, runtime_context)

      Workflow job generator.

      :param joborder: inputs of the job submission
      :param output_callbacks: method to fetch step outputs and corresponding step details
      :param runtime_context: configs about execution environment
      :return:



   
   .. method:: collect_output_ports(self, ports, builder, outdir, compute_checksum=True, jobname='', readers=None)



   
   .. method:: collect_output(self, schema, builder, outdir, fs_access, compute_checksum=True)




.. py:class:: WpsWorkflowJob(builder, joborder, requirements, hints, name, wps_process, expected_outputs)

   Bases: :class:`cwltool.job.JobBase`

   
   .. method:: run(self, runtimeContext, tmpdir_lock=None)



   
   .. method:: execute(self, runtime, env, runtime_context)