X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/340b992768b4460ef27b1102f7065381be96f2ea..5a84b3bf9b7bf9a1d07e9595b2453c4133ffd23d:/src/store/processes/processes-actions.ts diff --git a/src/store/processes/processes-actions.ts b/src/store/processes/processes-actions.ts index 2c7b8cff23..6f1d23b0b2 100644 --- a/src/store/processes/processes-actions.ts +++ b/src/store/processes/processes-actions.ts @@ -53,9 +53,11 @@ export const loadSubprocesses = (containerUuid: string) => } }; +const MAX_AMOUNT_OF_SUBPROCESSES = 10000; + export const loadContainerRequests = (filters: string) => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { - const { items } = await services.containerRequestService.list({ filters }); + const { items } = await services.containerRequestService.list({ filters, limit: MAX_AMOUNT_OF_SUBPROCESSES }); dispatch(updateResources(items)); return items; }; @@ -67,6 +69,16 @@ export const loadContainers = (filters: string) => return items; }; +export const cancelRunningWorkflow = (uuid: string) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + try { + const process = await services.containerRequestService.update(uuid, { priority: 0 }); + return process; + } catch (e) { + throw new Error('Could not cancel the process.'); + } + }; + export const reRunProcess = (processUuid: string, workflowUuid: string) => (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { const process = getResource(processUuid)(getState().resources); @@ -81,15 +93,15 @@ export const reRunProcess = (processUuid: string, workflowUuid: string) => const basicInitialData: RunProcessBasicFormData = { name: `Copy of: ${process.name}`, description: process.description }; dispatch(initialize(RUN_PROCESS_BASIC_FORM, basicInitialData)); - const advancedInitialData: RunProcessAdvancedFormData = { - output: process.outputName, - runtime: process.schedulingParameters.maxRunTime, + const advancedInitialData: RunProcessAdvancedFormData = { + output: process.outputName, + runtime: process.schedulingParameters.maxRunTime, ram: process.runtimeConstraints.ram, vcpus: process.runtimeConstraints.vcpus, keepCacheRam: process.runtimeConstraints.keepCacheRam, api: process.runtimeConstraints.API - }; - dispatch(initialize(RUN_PROCESS_ADVANCED_FORM, advancedInitialData)); + }; + dispatch(initialize(RUN_PROCESS_ADVANCED_FORM, advancedInitialData)); dispatch(navigateToRunProcess); dispatch(goToStep(1));