Merge branch 'develop' into SHIP-1754-Consolidate-all-FinalityDepth-s…

…ettings
smartcontractkit · Jun 27, 2024 · 7ff582c · 7ff582c
2 parents dc4fb58 + 7a3ba8e
commit 7ff582c
Showing 1 changed file with 18 additions and 2 deletions.
diff --git a/core/services/workflows/engine.go b/core/services/workflows/engine.go
@@ -355,9 +355,25 @@ func (e *Engine) registerTrigger(ctx context.Context, t *triggerCapability, trig
 			}}
 	}
 
+	e.wg.Add(1)
 	go func() {
-		for event := range eventsCh {
-			e.triggerEvents <- event
+		defer e.wg.Done()
+
+		for {
+			select {
+			case <-e.stopCh:
+				return
+			case event, isOpen := <-eventsCh:
+				if !isOpen {
+					return
+				}
+
+				select {
+				case <-e.stopCh:
+					return
+				case e.triggerEvents <- event:
+				}
+			}
 		}
 	}()