X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/7a2f0082071947bfec27ed4f2a16250e1d611d21..d87ff106a9f51defe5aafab2ad23dc1dee267b29:/src/models/workflow.ts diff --git a/src/models/workflow.ts b/src/models/workflow.ts index 3a38348e..6d21dbc7 100644 --- a/src/models/workflow.ts +++ b/src/models/workflow.ts @@ -11,9 +11,9 @@ export interface WorkflowResource extends Resource { description: string; definition: string; } -export interface WorkflowResoruceDefinition { +export interface WorkflowResourceDefinition { cwlVersion: string; - $graph: Array; + $graph?: Array; } export interface Workflow { class: 'Workflow'; @@ -22,6 +22,7 @@ export interface Workflow { inputs: CommandInputParameter[]; outputs: any[]; steps: any[]; + hints?: ProcessRequirement[]; } export interface CommandLineTool { @@ -29,6 +30,21 @@ export interface CommandLineTool { id: string; inputs: CommandInputParameter[]; outputs: any[]; + hints?: ProcessRequirement[]; +} + +export type ProcessRequirement = GenericProcessRequirement | WorkflowRunnerResources; + +export interface GenericProcessRequirement { + class: string; +} + +export interface WorkflowRunnerResources { + class: 'http://arvados.org/cwl#WorkflowRunnerResources'; + ramMin?: number; + coresMin?: number; + keep_cache?: number; + acrContainerImage?: string; } export type CommandInputParameter = @@ -116,19 +132,28 @@ export type DirectoryArrayCommandInputParameter = GenericArrayCommandInputParame export type WorkflowInputsData = { [key: string]: boolean | number | string | File | Directory; }; -export const parseWorkflowDefinition = (workflow: WorkflowResource): WorkflowResoruceDefinition => { +export const parseWorkflowDefinition = (workflow: WorkflowResource): WorkflowResourceDefinition => { const definition = safeLoad(workflow.definition); return definition; }; -export const getWorkflowInputs = (workflowDefinition: WorkflowResoruceDefinition) => { - const mainWorkflow = workflowDefinition.$graph.find(item => item.class === 'Workflow' && item.id === '#main'); +export const getWorkflow = (workflowDefinition: WorkflowResourceDefinition) => { + if (!workflowDefinition.$graph) { return undefined; } + const mainWorkflow = workflowDefinition.$graph.find(item => item.id === '#main'); return mainWorkflow - ? mainWorkflow.inputs + ? mainWorkflow : undefined; }; + +export const getWorkflowInputs = (workflowDefinition: WorkflowResourceDefinition) => { + if (!workflowDefinition) { return undefined; } + return getWorkflow(workflowDefinition) + ? getWorkflow(workflowDefinition)!.inputs + : undefined; +}; + export const getInputLabel = (input: CommandInputParameter) => { - return `${input.label || input.id}`; + return `${input.label || input.id.split('/').pop()}`; }; export const isRequiredInput = ({ type }: CommandInputParameter) => {