diff options
| -rw-r--r-- | tests/plugins/jobs/jobs_beanstalk_test.go | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/tests/plugins/jobs/jobs_beanstalk_test.go b/tests/plugins/jobs/jobs_beanstalk_test.go index 39a7f443..8e74c7cc 100644 --- a/tests/plugins/jobs/jobs_beanstalk_test.go +++ b/tests/plugins/jobs/jobs_beanstalk_test.go @@ -426,6 +426,18 @@ func TestBeanstalkStats(t *testing.T) { assert.Equal(t, out.Driver, "beanstalk") assert.Equal(t, out.Queue, "default") + // try 5 times + if out.Active == 0 { + for i := 0; i < 5; i++ { + time.Sleep(time.Second) + out = &jobState.State{} + t.Run("Stats", stats(out)) + if out.Active == 1 { + break + } + } + } + assert.Equal(t, int64(1), out.Active) assert.Equal(t, int64(1), out.Delayed) assert.Equal(t, int64(0), out.Reserved) |