In order correction (#202)

inst/startup/merger.R

@@ -63,8 +63,19 @@ if (typeof(cloudCombine) == "list" && enableCloudCombine) {
 
       results <- vector("list", length(files))
 
-      for (i in 1:length(files)) {
-        task <- readRDS(files[i])
+      for (i in 1:batchTasksCount) {
+        taskPath <- file.path(
+          batchTaskWorkingDirectory,
+          "result",
+          paste0(i, "-result.rds")
+        )
+
+        # Remove file from task list
+        if (!file.exists(taskPath)) {
+          next
+        }
+
+        task <- readRDS(taskPath)
 
         if (isError(task)) {
           if (errorHandling == "stop") {
@@ -88,15 +99,15 @@ if (typeof(cloudCombine) == "list" && enableCloudCombine) {
     }
     else if (errorHandling == "pass") {
       for (i in 1:batchTasksCount) {
-        taskResult <-
+        taskPath <-
           file.path(
             batchTaskWorkingDirectory,
             "result",
-            paste0(batchJobId, "-task", i, "-result.rds")
+            paste0(i, "-result.rds")
           )
 
-        if (file.exists(taskResult)) {
-          task <- readRDS(taskResult)
+        if (file.exists(taskPath)) {
+          task <- readRDS(taskPath)
           for (t in 1:length(task)) {
             results[count] <- task[t]
             count <- count + 1