From 9694d9aa7d716041f466e6670fd32447542a735b Mon Sep 17 00:00:00 2001 From: Mihajlo Pavlovic Date: Tue, 24 Dec 2024 13:45:33 +0100 Subject: [PATCH 1/2] Fix publishing service batch scheduling --- src/service/publish-service.js | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/service/publish-service.js b/src/service/publish-service.js index cfcab86bd..3c8dfe1f6 100644 --- 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); } } From 71e6ffcaa64135153d5f873e75c035e4bc8a0699 Mon Sep 17 00:00:00 2001 From: Mihajlo Pavlovic Date: Tue, 24 Dec 2024 13:47:54 +0100 Subject: [PATCH 2/2] Version bump --- package-lock.json | 4 ++-- package.json | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/package-lock.json b/package-lock.json index 366f111e8..6f6de7da0 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "origintrail_node", - "version": "8.0.0-sigma.13", + "version": "8.0.0-sigma.14", "lockfileVersion": 2, "requires": true, "packages": { "": { "name": "origintrail_node", - "version": "8.0.0-sigma.13", + "version": "8.0.0-sigma.14", "license": "ISC", "dependencies": { "@comunica/query-sparql": "^2.4.3", diff --git a/package.json b/package.json index 423cf926e..ce65fce55 100644 --- 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",