added responseCollector <- &pubsub2.Message{} when local worker hangs

masa-finance · Aug 2, 2024 · f789126 · f789126
1 parent 8bc5d80
commit f789126
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/workers/workers.go b/pkg/workers/workers.go
@@ -222,6 +222,7 @@ func SendWork(node *masa.OracleNode, m *pubsub2.Message) {
 			result, err := future.Result()
 			if err != nil {
 				logrus.Errorf("[-] Error receiving response from local worker: %v", err)
+				responseCollector <- &pubsub2.Message{}
 				return
 			}
 			response := result.(*messages.Response)