ParslService

class lsst.ctrl.bps.parsl.ParslService(config)

Bases: BaseWmsService

Parsl-based implementation for the WMS interface.

Methods Summary

prepare(config, generic_workflow[, out_prefix])	Convert a generic workflow to a Parsl pipeline.
restart(out_prefix)	Restart a workflow from the point of failure.
submit(workflow, **kwargs)	Submit a single WMS workflow.

Methods Documentation

prepare(config: BpsConfig, generic_workflow: GenericWorkflow, out_prefix: str | None = None) → BaseWmsWorkflow

Convert a generic workflow to a Parsl pipeline.

Parameters

configlsst.ctrl.bps.BpsConfig

Configuration of the workflow.

generic_workflowlsst.ctrl.bps.generic_workflow.GenericWorkflow

Generic representation of a single workflow.

out_prefixstr or None

Prefix for WMS output files.

Returns

workflowParslWorkflow

Workflow that will execute the jobs.

restart(out_prefix: str) → tuple[str, str, str]

Restart a workflow from the point of failure.

Parameters

out_prefixstr

Id for workflow to be restarted. For this service, it is the prefix for WMS files, also known as the submitPath.

Returns

wms_idstr

Id of the restarted workflow. If restart failed, it will be set to None.

run_namestr

Name of the restarted workflow. If restart failed, it will be set to None.

messagestr

A message describing any issues encountered during the restart. If there were no issue, an empty string is returned.

submit(workflow: BaseWmsWorkflow, **kwargs: Any)

Submit a single WMS workflow.

Parameters

workflowlsst.ctrl.bps.BaseWmsWorkflow

Prepared WMS Workflow to submit for execution.

**kwargsAny

Additional modifiers to the configuration.