Record replication metrics for retrying tasks Bug: Issue 400654646 Change-Id: Ifb81f29965575fd0072e7aa10cda997c92f658b5
diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/pull/Source.java b/src/main/java/com/googlesource/gerrit/plugins/replication/pull/Source.java index 320e9ec..b1d553d 100644 --- a/src/main/java/com/googlesource/gerrit/plugins/replication/pull/Source.java +++ b/src/main/java/com/googlesource/gerrit/plugins/replication/pull/Source.java
@@ -710,7 +710,10 @@ if (fetchOp.setToRetry()) { postReplicationScheduledEvent(fetchOp); - pool.schedule(fetchOp, config.getRetryDelay(), TimeUnit.MINUTES); + pool.schedule( + queueMetrics.runWithMetrics(this, fetchOp), + config.getRetryDelay(), + TimeUnit.MINUTES); queueMetrics.incrementTaskRetrying(this); } else { fetchOp.canceledByReplication();