X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/ceca6c57cc7d0357ab74abd47b80633a885ec575..d416c9aa7b70da4f8998792a42616b991d882f26:/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 2c5c9b68..61597bb7 100644 --- a/src/store/run-process-panel/run-process-panel-actions.ts +++ b/src/store/run-process-panel/run-process-panel-actions.ts @@ -3,25 +3,34 @@ // SPDX-License-Identifier: AGPL-3.0 import { Dispatch } from 'redux'; -import { unionize, ofType, UnionOf } from "~/common/unionize"; -import { ServiceRepository } from "~/services/services"; -import { RootState } from '~/store/store'; -import { WorkflowResource } from '~/models/workflow'; -import { getFormValues } from 'redux-form'; -import { RUN_PROCESS_BASIC_FORM, RunProcessBasicFormData } from '~/views/run-process-panel/run-process-basic-form'; -import { RUN_PROCESS_INPUTS_FORM } from '~/views/run-process-panel/run-process-inputs-form'; -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 { isNotProjectItem } from '~/store/projects/project-create-actions'; +import { unionize, ofType, UnionOf } from "common/unionize"; +import { ServiceRepository } from "services/services"; +import { RootState } from 'store/store'; +import { getUserUuid } from "common/getuser"; +import { WorkflowResource, WorkflowRunnerResources, getWorkflow, getWorkflowInputs, parseWorkflowDefinition } from 'models/workflow'; +import { getFormValues, initialize } from 'redux-form'; +import { RUN_PROCESS_BASIC_FORM, RunProcessBasicFormData } from 'views/run-process-panel/run-process-basic-form'; +import { RUN_PROCESS_INPUTS_FORM } from 'views/run-process-panel/run-process-inputs-form'; +import { WorkflowInputsData } from 'models/workflow'; +import { createWorkflowMounts } from 'models/process'; +import { ContainerRequestState } from 'models/container-request'; +import { navigateTo } from '../navigation/navigation-action'; +import { + RunProcessAdvancedFormData, RUN_PROCESS_ADVANCED_FORM, VCPUS_FIELD, + KEEP_CACHE_RAM_FIELD, RAM_FIELD, RUNTIME_FIELD, OUTPUT_FIELD, RUNNER_IMAGE_FIELD +} from 'views/run-process-panel/run-process-advanced-form'; +import { dialogActions } from 'store/dialog/dialog-actions'; +import { setBreadcrumbs } from 'store/breadcrumbs/breadcrumbs-actions'; export const runProcessPanelActions = unionize({ + SET_PROCESS_PATHNAME: ofType(), SET_PROCESS_OWNER_UUID: ofType(), SET_CURRENT_STEP: ofType(), + SET_STEP_CHANGED: ofType(), SET_WORKFLOWS: ofType(), SET_SELECTED_WORKFLOW: ofType(), + SET_WORKFLOW_PRESETS: ofType(), + SELECT_WORKFLOW_PRESET: ofType(), SEARCH_WORKFLOWS: ofType(), RESET_RUN_PROCESS_PANEL: ofType<{}>(), }); @@ -31,6 +40,7 @@ export interface RunProcessSecondStepDataFormProps { description: string; } +export const SET_WORKFLOW_DIALOG = 'setWorkflowDialog'; export const RUN_PROCESS_SECOND_STEP_FORM_NAME = 'runProcessSecondStepFormName'; export type RunProcessPanelAction = UnionOf; @@ -38,7 +48,7 @@ export type RunProcessPanelAction = UnionOf; export const loadRunProcessPanel = () => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { try { - dispatch(runProcessPanelActions.RESET_RUN_PROCESS_PANEL()); + dispatch(setBreadcrumbs([{ label: 'Run Process' }])); const response = await services.workflowService.list(); dispatch(runProcessPanelActions.SET_WORKFLOWS(response.items)); } catch (e) { @@ -46,51 +56,144 @@ export const loadRunProcessPanel = () => } }; -export const setWorkflow = (workflow: WorkflowResource) => - async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { - dispatch(runProcessPanelActions.SET_SELECTED_WORKFLOW(workflow)); +export const openSetWorkflowDialog = (workflow: WorkflowResource) => + (dispatch: Dispatch, getState: () => RootState) => { + const selectedWorkflow = getState().runProcessPanel.selectedWorkflow; + const isStepChanged = getState().runProcessPanel.isStepChanged; + if (isStepChanged && selectedWorkflow && selectedWorkflow.uuid !== workflow.uuid) { + dispatch(dialogActions.OPEN_DIALOG({ + id: SET_WORKFLOW_DIALOG, + data: { + title: 'Form will be cleared', + text: 'Changing a workflow will clean all input fields in next step.', + confirmButtonLabel: 'Change Workflow', + workflow + } + })); + } else { + dispatch(setWorkflow(workflow, false)); + } }; -export const goToStep = (step: number) => runProcessPanelActions.SET_CURRENT_STEP(step); +export const getWorkflowRunnerSettings = (workflow: WorkflowResource) => { + const advancedFormValues = {}; + Object.assign(advancedFormValues, DEFAULT_ADVANCED_FORM_VALUES); + + const wf = getWorkflow(parseWorkflowDefinition(workflow)); + const hints = wf ? wf.hints : undefined; + if (hints) { + const resc = hints.find(item => item.class === 'http://arvados.org/cwl#WorkflowRunnerResources') as WorkflowRunnerResources | undefined; + if (resc) { + if (resc.ramMin) { advancedFormValues[RAM_FIELD] = resc.ramMin * (1024 * 1024); } + if (resc.coresMin) { advancedFormValues[VCPUS_FIELD] = resc.coresMin; } + if (resc.keep_cache) { advancedFormValues[KEEP_CACHE_RAM_FIELD] = resc.keep_cache * (1024 * 1024); } + if (resc.acrContainerImage) { advancedFormValues[RUNNER_IMAGE_FIELD] = resc.acrContainerImage; } + } + } + return advancedFormValues; +}; + +export const setWorkflow = (workflow: WorkflowResource, isWorkflowChanged = true) => + (dispatch: Dispatch, getState: () => RootState) => { + const isStepChanged = getState().runProcessPanel.isStepChanged; + + const advancedFormValues = getWorkflowRunnerSettings(workflow); + + if (isStepChanged && isWorkflowChanged) { + dispatch(runProcessPanelActions.SET_STEP_CHANGED(false)); + dispatch(runProcessPanelActions.SET_SELECTED_WORKFLOW(workflow)); + dispatch(loadPresets(workflow.uuid)); + dispatch(initialize(RUN_PROCESS_BASIC_FORM, { name: workflow.name })); + dispatch(initialize(RUN_PROCESS_ADVANCED_FORM, advancedFormValues)); + } + if (!isWorkflowChanged) { + dispatch(runProcessPanelActions.SET_SELECTED_WORKFLOW(workflow)); + dispatch(loadPresets(workflow.uuid)); + dispatch(initialize(RUN_PROCESS_BASIC_FORM, { name: workflow.name })); + dispatch(initialize(RUN_PROCESS_ADVANCED_FORM, advancedFormValues)); + } + }; + +export const loadPresets = (workflowUuid: string) => + async (dispatch: Dispatch, _: () => RootState, { workflowService }: ServiceRepository) => { + const { items } = await workflowService.presets(workflowUuid); + dispatch(runProcessPanelActions.SET_WORKFLOW_PRESETS(items)); + }; + +export const selectPreset = (preset: WorkflowResource) => + (dispatch: Dispatch) => { + dispatch(runProcessPanelActions.SELECT_WORKFLOW_PRESET(preset)); + const inputs = getWorkflowInputs(parseWorkflowDefinition(preset)) || []; + const values = inputs.reduce((values, input) => ({ + ...values, + [input.id]: input.default, + }), {}); + dispatch(initialize(RUN_PROCESS_INPUTS_FORM, values)); + }; + +export const goToStep = (step: number) => + (dispatch: Dispatch) => { + if (step === 1) { + dispatch(runProcessPanelActions.SET_STEP_CHANGED(true)); + } + dispatch(runProcessPanelActions.SET_CURRENT_STEP(step)); + }; export const runProcess = async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { 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 userUuid = getState().auth.user!.uuid; + const userUuid = getUserUuid(getState()); + if (!userUuid) { return; } const { processOwnerUuid, selectedWorkflow } = state.runProcessPanel; + const ownerUUid = processOwnerUuid ? processOwnerUuid : userUuid; if (selectedWorkflow) { + const advancedForm = getFormValues(RUN_PROCESS_ADVANCED_FORM)(state) as RunProcessAdvancedFormData || getWorkflowRunnerSettings(selectedWorkflow); const newProcessData = { - ownerUuid: isNotProjectItem ? userUuid : processOwnerUuid, + ownerUuid: ownerUUid, name: basicForm.name, description: basicForm.description, state: ContainerRequestState.COMMITTED, mounts: createWorkflowMounts(selectedWorkflow, normalizeInputKeys(inputsForm)), runtimeConstraints: { API: true, - vcpus: 1, - ram: 1073741824, + vcpus: advancedForm[VCPUS_FIELD], + ram: (advancedForm[KEEP_CACHE_RAM_FIELD] + advancedForm[RAM_FIELD]), }, - containerImage: 'arvados/jobs:1.1.4.20180618144723', + schedulingParameters: { + max_run_time: advancedForm[RUNTIME_FIELD] + }, + containerImage: advancedForm[RUNNER_IMAGE_FIELD], cwd: '/var/spool/cwl', command: [ 'arvados-cwl-runner', - '--local', '--api=containers', - `--project-uuid=${processOwnerUuid}`, + '--local', + `--project-uuid=${ownerUUid}`, '/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] : `Output from ${basicForm.name}`, + properties: { + template_uuid: selectedWorkflow.uuid, + workflowName: selectedWorkflow.name + }, + useExisting: false }; const newProcess = await services.containerRequestService.create(newProcessData); - dispatch(navigateToProcess(newProcess.uuid)); + dispatch(navigateTo(newProcess.uuid)); } }; +const DEFAULT_ADVANCED_FORM_VALUES: Partial = { + [VCPUS_FIELD]: 1, + [RAM_FIELD]: 1073741824, + [KEEP_CACHE_RAM_FIELD]: 268435456, + [RUNNER_IMAGE_FIELD]: "arvados/jobs" +}; + const normalizeInputKeys = (inputs: WorkflowInputsData): WorkflowInputsData => Object.keys(inputs).reduce((normalizedInputs, key) => ({ ...normalizedInputs,