| OLD | NEW |
| 1 // Copyright 2015 The LUCI Authors. All rights reserved. | 1 // Copyright 2015 The LUCI Authors. All rights reserved. |
| 2 // Use of this source code is governed under the Apache License, Version 2.0 | 2 // Use of this source code is governed under the Apache License, Version 2.0 |
| 3 // that can be found in the LICENSE file. | 3 // that can be found in the LICENSE file. |
| 4 | 4 |
| 5 package tumble | 5 package tumble |
| 6 | 6 |
| 7 import ( | 7 import ( |
| 8 "fmt" | 8 "fmt" |
| 9 "testing" | 9 "testing" |
| 10 "time" | 10 "time" |
| (...skipping 22 matching lines...) Expand all Loading... |
| 33 | 33 |
| 34 So(fireTasks(ctx, tt.GetConfig(ctx), map[taskShard]struc
t{}{ | 34 So(fireTasks(ctx, tt.GetConfig(ctx), map[taskShard]struc
t{}{ |
| 35 taskShard{10, minTS}: {}, | 35 taskShard{10, minTS}: {}, |
| 36 }), ShouldBeTrue) | 36 }), ShouldBeTrue) |
| 37 tt.Drain(ctx) | 37 tt.Drain(ctx) |
| 38 | 38 |
| 39 So(l.Has(logging.Info, | 39 So(l.Has(logging.Info, |
| 40 "Processing tumble shard.", map[string]interface
{}{"shard": uint64(10)}), | 40 "Processing tumble shard.", map[string]interface
{}{"shard": uint64(10)}), |
| 41 ShouldBeTrue) | 41 ShouldBeTrue) |
| 42 So(l.Has(logging.Info, | 42 So(l.Has(logging.Info, |
| 43 » » » » "early exit, 0001-02-03 05:05:10 +0000 UTC > 000
1-02-03 04:05:12 +0000 UTC", | 43 » » » » "early exit, 0001-02-03 05:05:10 +0000 UTC > 000
1-02-03 04:05:12 +0000 UTC", nil), |
| 44 » » » » map[string]interface{}{"clientID": "-62132730888
_10", "key": "tumble.10.lock"}), | |
| 45 ShouldBeTrue) | 44 ShouldBeTrue) |
| 46 }) | 45 }) |
| 47 }) | 46 }) |
| 48 } | 47 } |
| OLD | NEW |