[#11] fetcher: Fix flaky TestFetcherCancel
All checks were successful
/ Builds (1.21) (pull_request) Successful in 1m42s
/ Builds (1.22) (pull_request) Successful in 1m30s
/ DCO (pull_request) Successful in 1m54s
/ Vulncheck (pull_request) Successful in 2m13s
/ Lint (pull_request) Successful in 2m46s
/ Tests (1.21) (pull_request) Successful in 1m32s
/ Tests (1.22) (pull_request) Successful in 1m30s
All checks were successful
/ Builds (1.21) (pull_request) Successful in 1m42s
/ Builds (1.22) (pull_request) Successful in 1m30s
/ DCO (pull_request) Successful in 1m54s
/ Vulncheck (pull_request) Successful in 2m13s
/ Lint (pull_request) Successful in 2m46s
/ Tests (1.21) (pull_request) Successful in 1m32s
/ Tests (1.22) (pull_request) Successful in 1m30s
Signed-off-by: Denis Kirillov <d.kirillov@yadro.com>
This commit is contained in:
parent
84ed2f55e3
commit
0190bbbde3
1 changed files with 4 additions and 8 deletions
|
@ -205,12 +205,13 @@ func TestFetcherCancel(t *testing.T) {
|
||||||
key, err := keys.NewPrivateKey()
|
key, err := keys.NewPrivateKey()
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
mocks, err := initMocks(1, 3)
|
mocks, err := initMocks(1, 1)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
epochCh := make(chan uint64)
|
epochCh := make(chan uint64)
|
||||||
go func() {
|
go func() {
|
||||||
epochCh <- 1
|
epochCh <- 1
|
||||||
|
epochCh <- 2
|
||||||
close(epochCh)
|
close(epochCh)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
|
@ -228,13 +229,8 @@ func TestFetcherCancel(t *testing.T) {
|
||||||
|
|
||||||
f := NewJobProvider(ctx, cfg)
|
f := NewJobProvider(ctx, cfg)
|
||||||
|
|
||||||
ch := f.Jobs()
|
var res []Job
|
||||||
|
for job := range f.Jobs() {
|
||||||
res := []Job{<-ch}
|
|
||||||
cancel()
|
|
||||||
<-ctx.Done()
|
|
||||||
|
|
||||||
for job := range ch {
|
|
||||||
res = append(res, job)
|
res = append(res, job)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue