X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/454ef1c106b3d738526d65ecfae8db98ad7bebc2..c3644a28ef0a80c193361f56627bbe9e556aacaa:/src/store/run-process-panel/run-process-panel-actions.ts diff --git a/src/store/run-process-panel/run-process-panel-actions.ts b/src/store/run-process-panel/run-process-panel-actions.ts index 0cbd9cd6..f7649860 100644 --- a/src/store/run-process-panel/run-process-panel-actions.ts +++ b/src/store/run-process-panel/run-process-panel-actions.ts @@ -14,7 +14,7 @@ import { WorkflowInputsData } from '~/models/workflow'; import { createWorkflowMounts } from '~/models/process'; import { ContainerRequestState } from '~/models/container-request'; import { navigateToProcess } from '../navigation/navigation-action'; -import { RunProcessAdvancedFormData, RUN_PROCESS_ADVANCED_FORM } from '~/views/run-process-panel/run-process-advanced-form'; +import { RunProcessAdvancedFormData, RUN_PROCESS_ADVANCED_FORM, VCPUS_FIELD, RAM_FIELD, RUNTIME_FIELD, OUTPUT_FIELD, API_FIELD } from '~/views/run-process-panel/run-process-advanced-form'; import { isItemNotInProject, isProjectOrRunProcessRoute } from '~/store/projects/project-create-actions'; import { dialogActions } from '~/store/dialog/dialog-actions'; import { setBreadcrumbs } from '~/store/breadcrumbs/breadcrumbs-actions'; @@ -79,10 +79,12 @@ export const setWorkflow = (workflow: WorkflowResource, isWorkflowChanged = true dispatch(runProcessPanelActions.SET_STEP_CHANGED(false)); dispatch(runProcessPanelActions.SET_SELECTED_WORKFLOW(workflow)); dispatch(loadPresets(workflow.uuid)); + dispatch(initialize(RUN_PROCESS_ADVANCED_FORM, DEFAULT_ADVANCED_FORM_VALUES)); } if (!isWorkflowChanged) { dispatch(runProcessPanelActions.SET_SELECTED_WORKFLOW(workflow)); dispatch(loadPresets(workflow.uuid)); + dispatch(initialize(RUN_PROCESS_ADVANCED_FORM, DEFAULT_ADVANCED_FORM_VALUES)); } }; @@ -115,7 +117,7 @@ export const runProcess = async (dispatch: Dispatch, getState: () => RootSt const state = getState(); const basicForm = getFormValues(RUN_PROCESS_BASIC_FORM)(state) as RunProcessBasicFormData; const inputsForm = getFormValues(RUN_PROCESS_INPUTS_FORM)(state) as WorkflowInputsData; - const advancedForm = getFormValues(RUN_PROCESS_ADVANCED_FORM)(state) as RunProcessAdvancedFormData; + const advancedForm = getFormValues(RUN_PROCESS_ADVANCED_FORM)(state) as RunProcessAdvancedFormData || DEFAULT_ADVANCED_FORM_VALUES; const userUuid = getState().auth.user!.uuid; const router = getState(); const properties = getState().properties; @@ -129,28 +131,36 @@ export const runProcess = async (dispatch: Dispatch, getState: () => RootSt mounts: createWorkflowMounts(selectedWorkflow, normalizeInputKeys(inputsForm)), runtimeConstraints: { API: true, - vcpus: 1, - ram: 1073741824, + vcpus: advancedForm[VCPUS_FIELD], + ram: advancedForm[RAM_FIELD], + api: advancedForm[API_FIELD], + }, + schedulingParameters: { + maxRunTime: advancedForm[RUNTIME_FIELD] }, containerImage: 'arvados/jobs', cwd: '/var/spool/cwl', command: [ 'arvados-cwl-runner', - '--local', '--api=containers', - `--project-uuid=${processOwnerUuid}`, '/var/lib/cwl/workflow.json#main', '/var/lib/cwl/cwl.input.json' ], outputPath: '/var/spool/cwl', priority: 1, - outputName: advancedForm && advancedForm.output ? advancedForm.output : undefined, + outputName: advancedForm[OUTPUT_FIELD] ? advancedForm[OUTPUT_FIELD] : undefined, }; const newProcess = await services.containerRequestService.create(newProcessData); dispatch(navigateToProcess(newProcess.uuid)); } }; +export const DEFAULT_ADVANCED_FORM_VALUES: Partial = { + [VCPUS_FIELD]: 1, + [RAM_FIELD]: 1073741824, + [API_FIELD]: true, +}; + const normalizeInputKeys = (inputs: WorkflowInputsData): WorkflowInputsData => Object.keys(inputs).reduce((normalizedInputs, key) => ({ ...normalizedInputs,