mirror of
https://github.com/hibiken/asynq.git
synced 2024-11-10 11:31:58 +08:00
Fix build
This commit is contained in:
parent
5f20edcbd1
commit
8dfabfccb3
@ -8,6 +8,7 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"flag"
|
"flag"
|
||||||
|
"math"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"sync"
|
"sync"
|
||||||
@ -846,8 +847,8 @@ func TestDoneWithMaxCounter(t *testing.T) {
|
|||||||
|
|
||||||
processedTotalKey := base.ProcessedTotalKey(msg.Queue)
|
processedTotalKey := base.ProcessedTotalKey(msg.Queue)
|
||||||
ctx := context.Background()
|
ctx := context.Background()
|
||||||
if err := r.client.Set(ctx, processedTotalKey, base.MaxInt64, 0).Err(); err != nil {
|
if err := r.client.Set(ctx, processedTotalKey, math.MaxInt64, 0).Err(); err != nil {
|
||||||
t.Fatalf("Redis command failed: SET %q %v", processedTotalKey, base.MaxInt64)
|
t.Fatalf("Redis command failed: SET %q %v", processedTotalKey, math.MaxInt64)
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := r.Done(msg); err != nil {
|
if err := r.Done(msg); err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user