From 728a72e85bf2fc1d8f7a4f4934a9426bd43e1a46 Mon Sep 17 00:00:00 2001 From: Kevin Su Date: Sat, 7 Oct 2023 20:26:24 -0700 Subject: [PATCH] fixed tests Signed-off-by: Kevin Su --- .../go/tasks/pluginmachinery/internal/webapi/monitor_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flyteplugins/go/tasks/pluginmachinery/internal/webapi/monitor_test.go b/flyteplugins/go/tasks/pluginmachinery/internal/webapi/monitor_test.go index 96a5a15e0d..85467f5e6c 100644 --- a/flyteplugins/go/tasks/pluginmachinery/internal/webapi/monitor_test.go +++ b/flyteplugins/go/tasks/pluginmachinery/internal/webapi/monitor_test.go @@ -37,7 +37,7 @@ func Test_monitor(t *testing.T) { client.OnStatusMatch(ctx, mock.Anything).Return(core2.PhaseInfoSuccess(nil), nil) wg := sync.WaitGroup{} - wg.Add(4) + wg.Add(8) cacheObj, err := cache.NewAutoRefreshCache(rand.String(5), func(ctx context.Context, batch cache.Batch) (updatedBatch []cache.ItemSyncResponse, err error) { wg.Done() t.Logf("Syncing Item [%+v]", batch[0])