21364: added reset_items_available method Arvados-DCO-1.1-Signed-off-by: Lisa Knox...

[arvados.git] / services / keep-balance / integration_test.go

diff --git a/services/keep-balance/integration_test.go b/services/keep-balance/integration_test.go
index 18cfd121069dfdd3be476c4f016ad7853e73bc51..b4bf423cd73eec25fb4f1ef6c0dc3b58826cb8ae 100644 (file)
--- a/services/keep-balance/integration_test.go
+++ b/services/keep-balance/integration_test.go
@@ -86,7 +86,7 @@ func (s *integrationSuite) TestBalanceAPIFixtures(c *check.C) {
        for iter := 0; iter < 20; iter++ {
                logBuf.Reset()
                logger := logrus.New()
-               logger.Out = io.MultiWriter(&logBuf, os.Stderr)
+               logger.Out = io.MultiWriter(&logBuf, ctxlog.LogWriter(c.Log))
                opts := RunOptions{
                        CommitConfirmedFields: true,
                        Logger:                logger,
@@ -103,7 +103,7 @@ func (s *integrationSuite) TestBalanceAPIFixtures(c *check.C) {
                if iter == 0 {
                        c.Check(logBuf.String(), check.Matches, `(?ms).*ChangeSet{Pulls:1.*`)
                        c.Check(logBuf.String(), check.Not(check.Matches), `(?ms).*ChangeSet{.*Trashes:[^0]}*`)
-               } else if strings.Contains(logBuf.String(), "ChangeSet{Pulls:0") {
+               } else if !strings.Contains(logBuf.String(), "ChangeSet{Pulls:1") {
                        break
                }
                time.Sleep(200 * time.Millisecond)