File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -21,12 +21,12 @@ import (
21
21
"github.com/golang/mock/gomock"
22
22
"github.com/jmoiron/sqlx"
23
23
24
+ "github.com/stretchr/testify/require"
24
25
"github.com/uber/kraken/lib/persistedretry"
25
26
. "github.com/uber/kraken/lib/persistedretry/tagreplication"
26
27
"github.com/uber/kraken/localdb"
27
- "github.com/uber/kraken/mocks/lib/persistedretry/tagreplication"
28
+ mocktagreplication "github.com/uber/kraken/mocks/lib/persistedretry/tagreplication"
28
29
"github.com/uber/kraken/utils/testutil"
29
- "github.com/stretchr/testify/require"
30
30
)
31
31
32
32
type storeMocks struct {
@@ -109,7 +109,7 @@ func TestDatabaseNotLocked(t *testing.T) {
109
109
store := mocks .new ()
110
110
111
111
var wg sync.WaitGroup
112
- for i := 0 ; i < 1000 ; i ++ {
112
+ for i := 0 ; i < 200 ; i ++ {
113
113
wg .Add (1 )
114
114
go func () {
115
115
defer wg .Done ()
Original file line number Diff line number Diff line change @@ -18,9 +18,9 @@ import (
18
18
"testing"
19
19
"time"
20
20
21
+ "github.com/stretchr/testify/require"
21
22
"github.com/uber/kraken/lib/persistedretry"
22
23
"github.com/uber/kraken/localdb"
23
- "github.com/stretchr/testify/require"
24
24
)
25
25
26
26
func checkTask (t * testing.T , expected * Task , result persistedretry.Task ) {
@@ -75,7 +75,7 @@ func TestDatabaseNotLocked(t *testing.T) {
75
75
store := NewStore (db )
76
76
77
77
var wg sync.WaitGroup
78
- for i := 0 ; i < 1000 ; i ++ {
78
+ for i := 0 ; i < 200 ; i ++ {
79
79
wg .Add (1 )
80
80
go func () {
81
81
defer wg .Done ()
You can’t perform that action at this time.
0 commit comments