Merge branch '15020-collection-with-the-same-content-adress'

[arvados-workbench2.git] / src / store / processes / processes-actions.ts

diff --git a/src/store/processes/processes-actions.ts b/src/store/processes/processes-actions.ts
index 2c7b8cff2361f270dc72576907535edef1e06739..6f1d23b0b2e9258538e9d4680f81805c26589adf 100644 (file)
--- 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<any>(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<any>(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<any>(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<any>(initialize(RUN_PROCESS_ADVANCED_FORM, advancedInitialData));
+            };
+            dispatch<any>(initialize(RUN_PROCESS_ADVANCED_FORM, advancedInitialData));
 
             dispatch<any>(navigateToRunProcess);
             dispatch<any>(goToStep(1));