shutdown emitter in tier 2

streamingfast · Mar 27, 2024 · 97f92b5 · 97f92b5
1 parent 5ea165e
commit 97f92b5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/service/tier2.go b/service/tier2.go
@@ -179,6 +179,9 @@ func (s *Tier2Service) ProcessRange(request *pbssinternal.ProcessRangeRequest, s
 	if err != nil {
 		return connect.NewError(connect.CodeInternal, fmt.Errorf("unable to initialize dmetering: %w", err))
 	}
+	defer func() {
+		emitter.Shutdown(nil)
+	}()
 
 	ctx = context.WithValue(ctx, "event_emitter", emitter)