t.Run("retry task success", func(t *testing.T) {
        r := &wait.Retrier{
            Interval: 100 * time.Millisecond,
            MaxRetry: 3,
        }