Merge pull request #3593 from OriginTrail/publish-scheduling-fix

Publish scheduling fix
OriginTrail · Dec 24, 2024 · 7967d08 · 7967d08
2 parents c80fb36 + 71e6ffc
commit 7967d08
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 4 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "origintrail_node",
-    "version": "8.0.0-sigma.13",
+    "version": "8.0.0-sigma.14",
     "description": "OTNode V8",
     "main": "index.js",
     "type": "module",

diff --git a/src/service/publish-service.js b/src/service/publish-service.js
@@ -97,7 +97,11 @@ class PublishService extends OperationService {
         // Not all requests sent, still possible to reach minimum replication,
         // schedule requests for leftover nodes
         const potentialCompletedNumber = completedNumber + leftoverNodes.length;
-        if (leftoverNodes.length > 0 && potentialCompletedNumber >= minAckResponses) {
+        if (
+            leftoverNodes.length > 0 &&
+            potentialCompletedNumber >= minAckResponses &&
+            (totalResponses - 1) % batchSize === 0
+        ) {
             await this.scheduleOperationForLeftoverNodes(command.data, leftoverNodes);
         }
     }