apsbits.demo_instrument.plans.dm_plans#

Plans in support of APS Data Management#

`dm_kickoff_workflow`(run, argsDict[, ...])	Start a DM workflow for this bluesky run and share run's metadata with DM.
`dm_list_processing_jobs`([exclude])	Show all the DM jobs with status not excluded.
`dm_submit_workflow_job`(workflowName, argsDict)	Low-level plan stub to submit a job to a DM workflow.

Functions

`dm_kickoff_workflow`(run, argsDict[, ...])	Start a DM workflow for this bluesky run and share run's metadata with DM.
`dm_list_processing_jobs`([exclude])	Show all the DM jobs with status not excluded.
`dm_submit_workflow_job`(workflowName, argsDict)	Low-level plan stub to submit a job to a DM workflow.

apsbits.demo_instrument.plans.dm_plans.dm_kickoff_workflow(run, argsDict, timeout=None, wait=False)[source]#

Start a DM workflow for this bluesky run and share run’s metadata with DM.

PARAMETERS:

run (obj): Bluesky run object (such as ‘run = cat[uid]’).

argsDict (dict): Dictionary of parameters needed by ‘workflowName’.: At minimum, most workflows expect these keys: ‘filePath’ and ‘experimentName’. Consult the workflow for the expected content of ‘argsDict’.
timeout (number): When should bluesky stop reporting on this: DM workflow job (if it has not ended). Units are seconds. Default is forever.
wait (bool): Should this plan stub wait for the job to end?: Default is ‘False’.

apsbits.demo_instrument.plans.dm_plans.dm_list_processing_jobs(exclude=None)[source]#

Show all the DM jobs with status not excluded.

Excluded status (default): ‘done’, ‘failed’

apsbits.demo_instrument.plans.dm_plans.dm_submit_workflow_job(workflowName, argsDict)[source]#

Low-level plan stub to submit a job to a DM workflow.

It is recommended to use dm_kickoff_workflow() instead. This plan does not share run metadata with DM.

PARAMETERS:

workflowName (str): Name of the DM workflow to be run.

argsDict (dict): Dictionary of parameters needed by ‘workflowName’.: At minimum, most workflows expect these keys: ‘filePath’ and ‘experimentName’. Consult the workflow for the expected content of ‘argsDict’.