X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/019459c71713b979cb4cc34ec3a91a947d2c235a..5d95075cdfdc2ca21f262f23355320f8aa96b25e:/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 7112f715..3cc6e713 100644 --- a/src/store/run-process-panel/run-process-panel-actions.ts +++ b/src/store/run-process-panel/run-process-panel-actions.ts @@ -6,22 +6,34 @@ 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 { 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 { navigateToProcess } from '../navigation/navigation-action'; -import { RunProcessAdvancedFormData, RUN_PROCESS_ADVANCED_FORM } from '~/views/run-process-panel/run-process-advanced-form'; +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 { matchProjectRoute } from '~/routes/routes'; 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(), - SEARCH_WORKFLOWS: ofType() + SET_WORKFLOW_PRESETS: ofType(), + SELECT_WORKFLOW_PRESET: ofType(), + SEARCH_WORKFLOWS: ofType(), + RESET_RUN_PROCESS_PANEL: ofType<{}>(), }); export interface RunProcessSecondStepDataFormProps { @@ -29,6 +41,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; @@ -36,6 +49,7 @@ export type RunProcessPanelAction = UnionOf; export const loadRunProcessPanel = () => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { try { + dispatch(setBreadcrumbs([{ label: 'Run Process' }])); const response = await services.workflowService.list(); dispatch(runProcessPanelActions.SET_WORKFLOWS(response.items)); } catch (e) { @@ -43,50 +57,141 @@ 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 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; } + if (resc.coresMin) { advancedFormValues[VCPUS_FIELD] = resc.coresMin; } + if (resc.keep_cache) { advancedFormValues[KEEP_CACHE_RAM_FIELD] = resc.keep_cache; } + 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_ADVANCED_FORM, advancedFormValues)); + } + if (!isWorkflowChanged) { + dispatch(runProcessPanelActions.SET_SELECTED_WORKFLOW(workflow)); + dispatch(loadPresets(workflow.uuid)); + 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 goToStep = (step: number) => runProcessPanelActions.SET_CURRENT_STEP(step); +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 = getUserUuid(getState()); + if (!userUuid) { return; } + const pathname = getState().runProcessPanel.processPathname; const { processOwnerUuid, selectedWorkflow } = state.runProcessPanel; + const ownerUUid = !matchProjectRoute(pathname) ? userUuid : processOwnerUuid; if (selectedWorkflow) { + const advancedForm = getFormValues(RUN_PROCESS_ADVANCED_FORM)(state) as RunProcessAdvancedFormData || getWorkflowRunnerSettings(selectedWorkflow); const newProcessData = { - ownerUuid: 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[RAM_FIELD], + }, + schedulingParameters: { + max_run_time: advancedForm[RUNTIME_FIELD] }, - containerImage: 'arvados/jobs:1.1.4.20180618144723', + 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] : undefined, + properties: { + workflowUuid: selectedWorkflow.uuid, + workflowName: selectedWorkflow.name + } }; const newProcess = await services.containerRequestService.create(newProcessData); - dispatch(navigateToProcess(newProcess.uuid)); + dispatch(navigateTo(newProcess.uuid)); } }; +export const DEFAULT_ADVANCED_FORM_VALUES: Partial = { + [VCPUS_FIELD]: 1, + [RAM_FIELD]: 1073741824, + [RUNNER_IMAGE_FIELD]: "arvados/jobs" +}; + const normalizeInputKeys = (inputs: WorkflowInputsData): WorkflowInputsData => Object.keys(inputs).reduce((normalizedInputs, key) => ({ ...normalizedInputs,