From abb6d737a4933cdc82d85e659a2278f81fd7247d Mon Sep 17 00:00:00 2001 From: Steven Guiheux Date: Fri, 3 Jul 2020 09:09:00 +0200 Subject: [PATCH] fix: subscribe to queue --- sdk/cdsclient/client_queue.go | 1 + 1 file changed, 1 insertion(+) 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 {