diff --git a/sdk/cdsclient/client_queue.go b/sdk/cdsclient/client_queue.go
index 66894aa4dd..ca2b0a0c28 100644
--- a/sdk/cdsclient/client_queue.go
+++ b/sdk/cdsclient/client_queue.go
@@ -69,6 +69,7 @@ func (c *client) QueuePolling(ctx context.Context, jobs chan<- sdk.WorkflowNodeJ
 	})
 	chanMessageToSend <- sdk.WebsocketFilter{
 		Queue: true,
+		Type:  sdk.WebsocketFilterTypeQueue,
 	}
 
 	for {