| Index: logdog/client/coordinator/query.go
|
| diff --git a/logdog/client/coordinator/query.go b/logdog/client/coordinator/query.go
|
| index 0901b4144d93fe8bfffd1ca876a7aab2ead78d60..c8899bd6c82d41e95760e1abb6f829fb8021660b 100644
|
| --- a/logdog/client/coordinator/query.go
|
| +++ b/logdog/client/coordinator/query.go
|
| @@ -5,7 +5,6 @@
|
| package coordinator
|
|
|
| import (
|
| - "fmt"
|
| "time"
|
|
|
| "github.com/luci/luci-go/common/proto/google"
|
| @@ -157,12 +156,8 @@ func (c *Client) Query(ctx context.Context, project cfgtypes.ProjectName, path s
|
| return normalizeError(err)
|
| }
|
|
|
| - for i, s := range resp.Streams {
|
| - st, err := loadLogStream(resp.Project, types.StreamPath(s.Path), s.State, s.Desc)
|
| - if err != nil {
|
| - return fmt.Errorf("failed to load stream state #%d: %v", i, err)
|
| - }
|
| -
|
| + for _, s := range resp.Streams {
|
| + st := loadLogStream(resp.Project, types.StreamPath(s.Path), s.State, s.Desc)
|
| if !cb(st) {
|
| return nil
|
| }
|
|
|