fix panic

beam-cloud · Apr 18, 2024 · 4cf530d · 4cf530d
1 parent 0878552
commit 4cf530d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/abstractions/taskqueue/taskqueue.go b/internal/abstractions/taskqueue/taskqueue.go
@@ -448,7 +448,7 @@ func (tq *RedisTaskQueue) TaskQueueMonitor(req *pb.TaskQueueMonitorRequest, stre
 					return
 
 				case msg := <-messages:
-					if msg.Payload == task.ExternalId {
+					if msg != nil && task != nil && msg.Payload == task.ExternalId {
 						cancelFlag <- true
 						return
 					}