From d29ab76a9347b1d47287b252a7ec775340726822 Mon Sep 17 00:00:00 2001 From: Nikki Dag Date: Tue, 17 Jun 2025 16:29:26 -0500 Subject: [PATCH] Stop Nexus worker --- internal/internal_worker.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/internal/internal_worker.go b/internal/internal_worker.go index 8aeaf7a44..6186389f6 100644 --- a/internal/internal_worker.go +++ b/internal/internal_worker.go @@ -1273,6 +1273,9 @@ func (aw *AggregatedWorker) Stop() { if !util.IsInterfaceNil(aw.sessionWorker) { aw.sessionWorker.Stop() } + if !util.IsInterfaceNil(aw.nexusWorker) { + aw.nexusWorker.Stop() + } aw.logger.Info("Stopped Worker") }