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 |