From fcd0304a63eb6a4e76ecfa46a4873343e53b6d96 Mon Sep 17 00:00:00 2001 From: Shawna Monero Date: Fri, 3 May 2024 08:26:04 -0700 Subject: [PATCH] forgot handle func and change registerjob channel --- server/neptune/temporalworker/job/noop_stream_handler.go | 1 + 1 file changed, 1 insertion(+) diff --git a/server/neptune/temporalworker/job/noop_stream_handler.go b/server/neptune/temporalworker/job/noop_stream_handler.go index d45e2b825..2af8ba0ed 100644 --- a/server/neptune/temporalworker/job/noop_stream_handler.go +++ b/server/neptune/temporalworker/job/noop_stream_handler.go @@ -30,6 +30,7 @@ func (n *NoopStreamHandler) CloseJob(ctx context.Context, jobID string) error { } func (n *NoopStreamHandler) CleanUp(ctx context.Context) error { + n.wg.Wait() return nil }