X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/1f9a8ec32f818d8e78d683ad5569b9e4ae0f693a..bf6ffb898a38a806ea0dd98daca7b3801923b62f:/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 314b7621..e0dada5c 100644 --- a/src/store/run-process-panel/run-process-panel-actions.ts +++ b/src/store/run-process-panel/run-process-panel-actions.ts @@ -3,27 +3,37 @@ // 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 { isItemNotInProject, isProjectOrRunProcessRoute } from '~/store/projects/project-create-actions'; -import { dialogActions } from '~/store/dialog/dialog-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'; +import { getResource } from 'store/resources/resources'; +import { ProjectResource } from "models/project"; +import { UserResource } from "models/user"; 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<{}>(), }); @@ -41,7 +51,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) { @@ -57,7 +67,7 @@ export const openSetWorkflowDialog = (workflow: WorkflowResource) => dispatch(dialogActions.OPEN_DIALOG({ id: SET_WORKFLOW_DIALOG, data: { - title: 'Data loss warning', + title: 'Form will be cleared', text: 'Changing a workflow will clean all input fields in next step.', confirmButtonLabel: 'Change Workflow', workflow @@ -68,20 +78,70 @@ export const openSetWorkflowDialog = (workflow: WorkflowResource) => } }; +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); + + let owner = getResource(getState().runProcessPanel.processOwnerUuid)(getState().resources); + const userUuid = getUserUuid(getState()); + if (!owner || !userUuid || owner.writableBy.indexOf(userUuid) === -1) { + owner = undefined; + } + 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, owner })); + 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, owner })); + 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, getState: () => RootState) => { + (dispatch: Dispatch) => { if (step === 1) { dispatch(runProcessPanelActions.SET_STEP_CHANGED(true)); } @@ -92,42 +152,57 @@ 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 userUuid = getState().auth.user!.uuid; - const router = getState(); - const properties = getState().properties; + const userUuid = getUserUuid(getState()); + if (!userUuid) { return; } const { processOwnerUuid, selectedWorkflow } = state.runProcessPanel; + const ownerUUid = basicForm.owner ? basicForm.owner.uuid : (processOwnerUuid ? processOwnerUuid : userUuid); if (selectedWorkflow) { + const advancedForm = getFormValues(RUN_PROCESS_ADVANCED_FORM)(state) as RunProcessAdvancedFormData || getWorkflowRunnerSettings(selectedWorkflow); const newProcessData = { - ownerUuid: isItemNotInProject(properties) || !isProjectOrRunProcessRoute(router) ? 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]), + }, + schedulingParameters: { + max_run_time: advancedForm[RUNTIME_FIELD] }, - containerImage: 'arvados/jobs', + 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,