X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/52b7b2934d5d74ee67ca13f8d1cc95f1379faddc..9833a2b9be1a722bd9aad08baf48ca072bde7ca7:/services/keep-balance/collection_test.go diff --git a/services/keep-balance/collection_test.go b/services/keep-balance/collection_test.go index a2200e1db9..3ab9d07b2e 100644 --- a/services/keep-balance/collection_test.go +++ b/services/keep-balance/collection_test.go @@ -5,10 +5,11 @@ package main import ( + "context" "sync" "time" - "git.curoverse.com/arvados.git/sdk/go/arvados" + "git.arvados.org/arvados.git/sdk/go/arvados" check "gopkg.in/check.v1" ) @@ -29,8 +30,8 @@ func (s *integrationSuite) TestIdenticalTimestamps(c *check.C) { longestStreak := 0 var lastMod time.Time sawUUID := make(map[string]bool) - err := EachCollection(s.client, pageSize, func(c arvados.Collection) error { - if c.ModifiedAt == nil { + err := EachCollection(context.Background(), s.client, pageSize, func(c arvados.Collection) error { + if c.ModifiedAt.IsZero() { return nil } if sawUUID[c.UUID] { @@ -39,14 +40,14 @@ func (s *integrationSuite) TestIdenticalTimestamps(c *check.C) { } got[trial] = append(got[trial], c.UUID) sawUUID[c.UUID] = true - if lastMod == *c.ModifiedAt { + if lastMod == c.ModifiedAt { streak++ if streak > longestStreak { longestStreak = streak } } else { streak = 0 - lastMod = *c.ModifiedAt + lastMod = c.ModifiedAt } return nil }, nil)