From 315fc00eac126019ca6ed611d42daa305426ab93 Mon Sep 17 00:00:00 2001 From: Jon Chambers Date: Fri, 20 Sep 2024 17:36:24 -0400 Subject: [PATCH] Lazily evaluate jobs to give max concurrency meaningful "teeth" --- .../whispersystems/textsecuregcm/scheduler/JobScheduler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/scheduler/JobScheduler.java b/service/src/main/java/org/whispersystems/textsecuregcm/scheduler/JobScheduler.java index 664d68a0c..87d0ae758 100644 --- 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)