Skip to content

Commit 5b7155b

Browse files
Copybara Servicecopybara-github
authored andcommitted
Fix another flaky test
PiperOrigin-RevId: 942178702
1 parent b33bdde commit 5b7155b

2 files changed

Lines changed: 10 additions & 2 deletions

File tree

fleetspeak/src/server/spanner/broadcaststore.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -229,9 +229,11 @@ func (d *Datastore) ListActiveBroadcasts(ctx context.Context) ([]*db.BroadcastIn
229229
"b.MessageLimit " +
230230
"FROM Broadcasts AS b " +
231231
"WHERE b.Sent < b.MessageLimit " +
232-
"AND (b.Broadcast.expiration_time IS NULL OR (b.Broadcast.expiration_time.seconds > @nowSec))",
232+
"AND (b.Broadcast.expiration_time IS NULL OR (b.Broadcast.expiration_time.seconds > @nowSec) " +
233+
"OR (b.Broadcast.expiration_time.seconds = @nowSec AND b.Broadcast.expiration_time.nanos > @nowNano))",
233234
Params: map[string]any{
234-
"nowSec": int64(now.Seconds),
235+
"nowSec": int64(now.Seconds),
236+
"nowNano": int64(now.Nanos),
235237
},
236238
}
237239

fleetspeak/src/server/spanner/spanner_test.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,8 +87,14 @@ func (e *spannerTestEnv) Clean() (db.Store, error) {
8787
e.current = s
8888
m := []*spanner.Mutation{
8989
spanner.Delete(s.clients, spanner.AllKeys()),
90+
spanner.Delete(s.clientLabels, spanner.AllKeys()),
91+
spanner.Delete(s.clientContacts, spanner.AllKeys()),
92+
spanner.Delete(s.clientContactMessages, spanner.AllKeys()),
9093
spanner.Delete(s.messages, spanner.AllKeys()),
94+
spanner.Delete(s.clientPendingMessages, spanner.AllKeys()),
95+
spanner.Delete(s.clientResourceUsageRecords, spanner.AllKeys()),
9196
spanner.Delete(s.broadcasts, spanner.AllKeys()),
97+
spanner.Delete(s.broadcastAllocations, spanner.AllKeys()),
9298
spanner.Delete(s.broadcastSent, spanner.AllKeys()),
9399
spanner.Delete(s.files, spanner.AllKeys()),
94100
}

0 commit comments

Comments
 (0)