issue #3131 fix for cluster runs, when run cluster workers - calculat…

…e configuration only ones and then just copy it
epam · Mar 31, 2023 · a145756 · a145756
1 parent 15954ad
commit a145756
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/api/src/main/java/com/epam/pipeline/manager/pipeline/PipelineRunManager.java b/api/src/main/java/com/epam/pipeline/manager/pipeline/PipelineRunManager.java
@@ -1284,9 +1284,10 @@ private void runClusterWorkers(PipelineRun run, PipelineStart runVO, String vers
                                    PipelineConfiguration configuration) {
         String parentId = Long.toString(run.getId());
         Integer nodeCount = configuration.getNodeCount();
+        final PipelineConfiguration workerConfigurationTemplate = configurationManager.generateWorkerConfiguration(
+                parentId, runVO, configuration, false, true);
         for (int i = 0; i < nodeCount; i++) {
-            final PipelineConfiguration workerConfiguration = configurationManager.generateWorkerConfiguration(
-                    parentId, runVO, configuration, false, true);
+            final PipelineConfiguration workerConfiguration = workerConfigurationTemplate.clone();
             launchPipeline(
                     workerConfiguration, pipeline, version, runVO.getInstanceType(), runVO.getConfigurationName(),
                     parentId, run.getId(), null, null, runVO.getRunSids(),

diff --git a/api/src/main/java/com/epam/pipeline/manager/pipeline/runner/CloudPlatformRunner.java b/api/src/main/java/com/epam/pipeline/manager/pipeline/runner/CloudPlatformRunner.java
@@ -167,9 +167,10 @@ private List<PipelineRun> runConfigurationEntry(RunConfigurationEntry entry,
         Pipeline pipeline = entry.getPipelineId() != null ? pipelineManager.load(entry.getPipelineId()) : null;
         List<PipelineRun> result = new ArrayList<>();
         log.debug("Launching total {} copies of entry {}", copies, entry.getName());
+        final PipelineConfiguration runConfigurationTemplate =
+                buildRunConfiguration(entry, configuration, clusterId, startNFS, startVO);
         for (int i = 0; i < copies; i++) {
-            final PipelineConfiguration runConfiguration =
-                    buildRunConfiguration(entry, configuration, clusterId, startNFS, startVO);
+            final PipelineConfiguration runConfiguration = runConfigurationTemplate.clone();
             //only first node may be a NFS server
             if (i != 0) {
                 runConfiguration.setCmdTemplate(WORKER_CMD_TEMPLATE);