From ebae5a82f13eebb6444d73cc7d4eb12fbeb7f0d0 Mon Sep 17 00:00:00 2001 From: KillianG Date: Thu, 17 Oct 2024 16:24:48 +0200 Subject: [PATCH] DROP THIS Refactor ReplicateObject.js to publish replication status on completion --- extensions/replication/tasks/ReplicateObject.js | 2 ++ 1 file changed, 2 insertions(+) diff --git a/extensions/replication/tasks/ReplicateObject.js b/extensions/replication/tasks/ReplicateObject.js index e4a481cd8..79633db3b 100644 --- a/extensions/replication/tasks/ReplicateObject.js +++ b/extensions/replication/tasks/ReplicateObject.js @@ -844,6 +844,8 @@ class ReplicateObject extends BackbeatTask { log.info('replication skipped: ' + 'source object version does not exist', { entry: sourceEntry.getLogInfo() }); + this._publishReplicationStatus( + sourceEntry, 'COMPLETED', { kafkaEntry, log }); return done(); } log.info('target object version does not exist, retrying ' +