From e556e2fbeb8a37608b2aacc5677863b0faa462c9 Mon Sep 17 00:00:00 2001 From: Tim Vaillancourt Date: Wed, 2 Oct 2024 21:23:29 +0200 Subject: [PATCH] fix test rebasing broke Signed-off-by: Tim Vaillancourt --- go/vt/throttler/throttler_test.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/go/vt/throttler/throttler_test.go b/go/vt/throttler/throttler_test.go index e3c7da3cdfe..c6374707e2a 100644 --- a/go/vt/throttler/throttler_test.go +++ b/go/vt/throttler/throttler_test.go @@ -411,8 +411,9 @@ func TestThreadFinished_SecondCallPanics(t *testing.T) { func TestThrottlerMaxLag(t *testing.T) { fc := &fakeClock{} - throttler, err := newThrottlerWithClock(t.Name(), "queries", 1, 1, 10, fc.now) + th, err := newThrottlerWithClock(t.Name(), "queries", 1, 1, 10, fc.now) require.NoError(t, err) + throttler := th.(*ThrottlerImpl) defer throttler.Close() require.NotNil(t, throttler) @@ -442,7 +443,7 @@ func TestThrottlerMaxLag(t *testing.T) { }() wg.Add(1) - go func(wg *sync.WaitGroup, ctx context.Context, throttler *Throttler, tabletType topodata.TabletType) { + go func(wg *sync.WaitGroup, ctx context.Context, throttler *ThrottlerImpl, tabletType topodata.TabletType) { defer wg.Done() for { select {