From d27e345310c124526dbcf0e5a8e2ce203b1f0a87 Mon Sep 17 00:00:00 2001 From: Michael Crosby Date: Tue, 5 Dec 2017 09:55:33 -0500 Subject: [PATCH] Fix event filters Signed-off-by: Michael Crosby Upstream-commit: a27abc619cc18ead61fa89f652871fac1b318658 Component: engine --- components/engine/libcontainerd/client_daemon.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/components/engine/libcontainerd/client_daemon.go b/components/engine/libcontainerd/client_daemon.go index 5c26bc257e..0a3502c347 100644 --- a/components/engine/libcontainerd/client_daemon.go +++ b/components/engine/libcontainerd/client_daemon.go @@ -681,7 +681,10 @@ func (c *client) processEventStream(ctx context.Context) { }() eventStream, err = c.remote.EventService().Subscribe(ctx, &eventsapi.SubscribeRequest{ - Filters: []string{"namespace==" + c.namespace + ",topic~=/tasks/.+"}, + Filters: []string{ + "namespace==" + c.namespace, + "topic~=/tasks/", + }, }, grpc.FailFast(false)) if err != nil { return