X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/b104bb15d23084f00745384b90845ad459181188..6ead1b122e52a587963383f6a15edf6dfc166ef6:/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 12d1eeb13a..5b082b8c28 100644 --- a/src/store/run-process-panel/run-process-panel-actions.ts +++ b/src/store/run-process-panel/run-process-panel-actions.ts @@ -13,13 +13,14 @@ import { RUN_PROCESS_INPUTS_FORM } from '~/views/run-process-panel/run-process-i 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, VCPUS_FIELD, RAM_FIELD, RUNTIME_FIELD, OUTPUT_FIELD } from '~/views/run-process-panel/run-process-advanced-form'; -import { isItemNotInProject, isProjectOrRunProcessRoute } from '~/store/projects/project-create-actions'; +import { navigateTo } from '../navigation/navigation-action'; +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 { 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(), @@ -45,7 +46,6 @@ export const loadRunProcessPanel = () => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { try { dispatch(setBreadcrumbs([{ label: 'Run Process' }])); - dispatch(runProcessPanelActions.RESET_RUN_PROCESS_PANEL()); const response = await services.workflowService.list(); dispatch(runProcessPanelActions.SET_WORKFLOWS(response.items)); } catch (e) { @@ -88,7 +88,7 @@ export const setWorkflow = (workflow: WorkflowResource, isWorkflowChanged = true } }; -const loadPresets = (workflowUuid: string) => +export const loadPresets = (workflowUuid: string) => async (dispatch: Dispatch, _: () => RootState, { workflowService }: ServiceRepository) => { const { items } = await workflowService.presets(workflowUuid); dispatch(runProcessPanelActions.SET_WORKFLOW_PRESETS(items)); @@ -119,12 +119,11 @@ export const runProcess = async (dispatch: Dispatch, getState: () => RootSt const inputsForm = getFormValues(RUN_PROCESS_INPUTS_FORM)(state) as WorkflowInputsData; 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; + const pathname = getState().runProcessPanel.processPathname; const { processOwnerUuid, selectedWorkflow } = state.runProcessPanel; if (selectedWorkflow) { const newProcessData = { - ownerUuid: isItemNotInProject(properties) || !isProjectOrRunProcessRoute(router) ? userUuid : processOwnerUuid, + ownerUuid: !matchProjectRoute(pathname) ? userUuid : processOwnerUuid, name: basicForm.name, description: basicForm.description, state: ContainerRequestState.COMMITTED, @@ -133,6 +132,7 @@ export const runProcess = async (dispatch: Dispatch, getState: () => RootSt API: true, vcpus: advancedForm[VCPUS_FIELD], ram: advancedForm[RAM_FIELD], + api: advancedForm[API_FIELD], }, schedulingParameters: { maxRunTime: advancedForm[RUNTIME_FIELD] @@ -142,21 +142,27 @@ export const runProcess = async (dispatch: Dispatch, getState: () => RootSt command: [ 'arvados-cwl-runner', '--api=containers', + '--local', '/var/lib/cwl/workflow.json#main', '/var/lib/cwl/cwl.input.json' ], outputPath: '/var/spool/cwl', priority: 1, 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, + [API_FIELD]: true, }; const normalizeInputKeys = (inputs: WorkflowInputsData): WorkflowInputsData =>