specify worker

ikhoon · Oct 18, 2024 · 4eaeece · 4eaeece
1 parent c663284
commit 4eaeece
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/com/linecorp/centraldogma/server/internal/mirror/MirrorRunner.java b/server/src/main/java/com/linecorp/centraldogma/server/internal/mirror/MirrorRunner.java
@@ -95,7 +95,7 @@ private CompletableFuture<MirrorResult> run(MirrorKey mirrorKey) {
                                              mirrorConfig.maxNumBytesPerMirror());
                     }, worker);
             // Remove the inflight request when the mirror task is done.
-            future.handleAsync((unused0, unused1) -> inflightRequests.remove(mirrorKey));
+            future.handleAsync((unused0, unused1) -> inflightRequests.remove(mirrorKey), worker);
             return future;
         } catch (Throwable e) {
             inflightRequests.remove(mirrorKey);