Skip to content

Commit

Permalink
feat(worker): Added worker pool health check probe
Browse files Browse the repository at this point in the history
  • Loading branch information
ekkinox committed Jul 17, 2024
1 parent 289c7e9 commit f8c3b81
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions worker/healthcheck/probe_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,6 @@ func TestWorkerProbe(t *testing.T) {
t.Parallel()

pool, err := worker.NewDefaultWorkerPoolFactory().Create(
worker.WithWorker(workers.NewClassicWorker()),
worker.WithWorker(workers.NewErrorWorker()),
)
assert.NoError(t, err)
Expand All @@ -67,6 +66,6 @@ func TestWorkerProbe(t *testing.T) {
res := probe.Check(context.Background())

assert.False(t, res.Success)
assert.Equal(t, "ClassicWorker: success, ErrorWorker: error", res.Message)
assert.Equal(t, "ErrorWorker: error", res.Message)
})
}

0 comments on commit f8c3b81

Please sign in to comment.