X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/0561bd0c3c07257fd58ded6c7cfa5feeae97af57..e8d1a643cdbc3a5f4c0e5c745da58d9f7e1248d8:/services/keep-balance/collection_test.go diff --git a/services/keep-balance/collection_test.go b/services/keep-balance/collection_test.go index a548b1ff9f..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,24 +30,24 @@ func (s *integrationSuite) TestIdenticalTimestamps(c *check.C) { longestStreak := 0 var lastMod time.Time sawUUID := make(map[string]bool) - err := EachCollection(&s.config.Client, pageSize, func(c arvados.Collection) error { - got[trial] = append(got[trial], c.UUID) - 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] { // dup return nil } + 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)