Fix event filters

Signed-off-by: Michael Crosby <crosbymichael@gmail.com> Upstream-commit: a27abc619cc18ead61fa89f652871fac1b318658 Component: engine
2017-12-05 09:55:33 -05:00
parent e1f6e66d66
commit d27e345310
1 changed files with 4 additions and 1 deletions
@@ -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