Lazily evaluate jobs to give max concurrency meaningful "teeth"

2024-09-20 17:36:24 -04:00 · 2024-09-20 17:36:24 -04:00 · 315fc00eac
parent 6142dcc7e6
commit 315fc00eac
1 changed files with 1 additions and 1 deletions
--- a/service/src/main/java/org/whispersystems/textsecuregcm/scheduler/JobScheduler.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/scheduler/JobScheduler.java
@ -153,7 +153,7 @@ public abstract class JobScheduler {
              ? item.get(ATTR_JOB_DATA).b().asByteArray()
              : null;

-          return Mono.fromFuture(processJob(jobData))
+          return Mono.fromFuture(() -> processJob(jobData))
              .doOnNext(outcome -> Metrics.counter(PROCESS_JOB_COUNTER_NAME,
                      SCHEDULER_NAME_TAG, getSchedulerName(),
                      OUTCOME_TAG, outcome)