Prevent sending back failed messages for the local workers

masa-finance · Jul 18, 2024 · b557a42 · b557a42
1 parent a20187c
commit b557a42
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/workers/workers.go b/pkg/workers/workers.go
@@ -317,6 +317,9 @@ func SendWork(node *masa.OracleNode, m *pubsub2.Message) {
 				if err != nil {
 					logrus.Debugf("Error getting response message: %v", err)
 					return
+				} else {
+					// don't send back failed messages here
+					return
 				}
 			}
 			workerDoneCh <- msg