[fix] Fix engine panic when we get a zero response (#12890)

smartcontractkit · Apr 19, 2024 · facaf9a · facaf9a
1 parent b2cd7ff
commit facaf9a
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/core/services/workflows/engine.go b/core/services/workflows/engine.go
@@ -219,7 +219,12 @@ func (e *Engine) loop(ctx context.Context) {
 		case <-ctx.Done():
 			e.logger.Debugw("shutting down loop")
 			return
-		case resp := <-e.triggerEvents:
+		case resp, isOpen := <-e.triggerEvents:
+			if !isOpen {
+				e.logger.Errorf("trigger events channel is no longer open, skipping")
+				continue
+			}
+
 			if resp.Err != nil {
 				e.logger.Errorf("trigger event was an error; not executing", resp.Err)
 				continue