Shard all issue actions
@@ -111,6 +111,7 @@ public class ApplicationOwnershipConfirmer extends ControllerMaintainer {
AtomicInteger attempts = new AtomicInteger(0);
AtomicInteger failures = new AtomicInteger(0);
for (Application application : applications())
+ if (isInCurrentShard(application.id()))
application.ownershipIssueId().ifPresent(issueId -> {
try {
attempts.incrementAndGet();
@@ -133,6 +134,7 @@ public class ApplicationOwnershipConfirmer extends ControllerMaintainer {
.withProductionDeployment()
.asList()
.stream()
+ .filter(application -> isInCurrentShard(application.id()))
.filter(application -> application.ownershipIssueId().isPresent())
.forEach(application -> {
attempts.incrementAndGet();
