From f1c153f39fb7f1014fd7deb6538be5b557014ccf Mon Sep 17 00:00:00 2001 From: Jon Chambers Date: Tue, 30 Jul 2024 17:53:10 -0400 Subject: [PATCH] Log max concurrency when starting/finishing experiments --- .../workers/FinishPushNotificationExperimentCommand.java | 2 ++ .../workers/StartPushNotificationExperimentCommand.java | 2 ++ 2 files changed, 4 insertions(+) diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/workers/FinishPushNotificationExperimentCommand.java b/service/src/main/java/org/whispersystems/textsecuregcm/workers/FinishPushNotificationExperimentCommand.java index 572b7569c..193103c1d 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/workers/FinishPushNotificationExperimentCommand.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/workers/FinishPushNotificationExperimentCommand.java @@ -70,6 +70,8 @@ public class FinishPushNotificationExperimentCommand extends AbstractCommandW final int maxConcurrency = namespace.getInt(MAX_CONCURRENCY_ARGUMENT); + log.info("Finishing \"{}\" with max concurrency: {}", experiment.getExperimentName(), maxConcurrency); + final AccountsManager accountsManager = commandDependencies.accountsManager(); final PushNotificationExperimentSamples pushNotificationExperimentSamples = commandDependencies.pushNotificationExperimentSamples(); diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/workers/StartPushNotificationExperimentCommand.java b/service/src/main/java/org/whispersystems/textsecuregcm/workers/StartPushNotificationExperimentCommand.java index 97a1c2e5a..c50f1d59b 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/workers/StartPushNotificationExperimentCommand.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/workers/StartPushNotificationExperimentCommand.java @@ -83,6 +83,8 @@ public class StartPushNotificationExperimentCommand extends AbstractSinglePas final PushNotificationExperimentSamples pushNotificationExperimentSamples = getCommandDependencies().pushNotificationExperimentSamples(); + log.info("Starting \"{}\" with max concurrency: {}", experiment.getExperimentName(), maxConcurrency); + accounts .flatMap(account -> Flux.fromIterable(account.getDevices()).map(device -> Tuples.of(account, device))) .doOnNext(ignored -> DEVICE_INSPECTED_COUNTER.increment())