Workflows

class indico.queries.workflow.ListWorkflows(dataset_ids=None, workflow_ids=None)

List all workflows visible to authenticated user

Parameters
  • dataset_ids (List[int], optional) – List of dataset ids to filter by. Defaults to None

  • workflow_ids (List[int], optional) – List of workflow ids to filter by Defaults to None

Returns

All the found Workflow objects

Return type

List[Workflow]

class indico.queries.workflow.WorkflowSubmission(workflow_id, files, submission=True)

Submit files to a workflow for processing

Parameters
  • workflow_id (int) – Id of workflow to submit files to

  • files (List[str]) – List of local file paths to submit

  • submission (bool, optional) – Process these files as normal submissions. Defaults to True. If False, files will be processed as AsyncJobs, ignoring any workflow post-processing steps like Review and with no record in the system

Returns

If submission, these will be submission ids.

Otherwise, they will be AsyncJob ids.

Return type

List[int]