diff options
| author | Patrick Steinhardt <psteinhardt@gitlab.com> | 2021-04-14 15:50:31 +0300 |
|---|---|---|
| committer | Patrick Steinhardt <psteinhardt@gitlab.com> | 2021-04-14 16:06:07 +0300 |
| commit | 9aacb55c9b85c1fc7e080c54ededcf692aee92a5 (patch) | |
| tree | 4d758ab1a376532c2b7a76f572002d3cabb8a0bc /internal/praefect/coordinator_test.go | |
| parent | 412b51fc5e86ff5f0075ddadce3e248fa47ae598 (diff) | |
tests: Fix random set of missing error checks
Various functions return error which we do not check. Fix these by
calling `require.NoError()` to catch any unexpected issues.
Diffstat (limited to 'internal/praefect/coordinator_test.go')
| -rw-r--r-- | internal/praefect/coordinator_test.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/praefect/coordinator_test.go b/internal/praefect/coordinator_test.go index ae38bdca9..8ab075f20 100644 --- a/internal/praefect/coordinator_test.go +++ b/internal/praefect/coordinator_test.go @@ -208,7 +208,7 @@ func TestStreamDirectorMutator(t *testing.T) { replEventWait.Add(1) // expected only one event to be created // this call creates new events in the queue and simulates usual flow of the update operation - streamParams.RequestFinalizer() + require.NoError(t, streamParams.RequestFinalizer()) replEventWait.Wait() // wait until event persisted (async operation) events, err := queueInterceptor.Dequeue(ctx, "praefect", "praefect-internal-2", 10) @@ -1078,7 +1078,7 @@ func TestAbsentCorrelationID(t *testing.T) { replEventWait.Add(1) // expected only one event to be created // must be run as it adds replication events to the queue - streamParams.RequestFinalizer() + require.NoError(t, streamParams.RequestFinalizer()) replEventWait.Wait() // wait until event persisted (async operation) jobs, err := queueInterceptor.Dequeue(ctx, conf.VirtualStorages[0].Name, conf.VirtualStorages[0].Nodes[1].Storage, 1) |