From f8c3b81d9987ef59857c80ed7eec2f194cd0ab6a Mon Sep 17 00:00:00 2001 From: Jonathan Vuillemin Date: Wed, 17 Jul 2024 13:53:57 +0200 Subject: [PATCH] feat(worker): Added worker pool health check probe --- worker/healthcheck/probe_test.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/worker/healthcheck/probe_test.go b/worker/healthcheck/probe_test.go index d751da2..da79142 100644 --- a/worker/healthcheck/probe_test.go +++ b/worker/healthcheck/probe_test.go @@ -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) @@ -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) }) }