Skip to content

Commit d078c93

Browse files
authored
chore: flaky oauth test (#4280)
1 parent 719396f commit d078c93

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

services/oauth/oauth_test.go

+5-2
Original file line numberDiff line numberDiff line change
@@ -126,6 +126,7 @@ func TestMultipleRequestsForOAuth(t *testing.T) {
126126
totalGoRoutines := 5
127127
var wg sync.WaitGroup
128128
var allJobStatus []int
129+
var allJobStatusMu sync.Mutex
129130

130131
dest := &backendconfig.DestinationT{
131132
ID: "dId",
@@ -151,14 +152,16 @@ func TestMultipleRequestsForOAuth(t *testing.T) {
151152
RudderAccountId: "accountId",
152153
AuthStatus: oauth.AuthStatusInactive,
153154
})
155+
allJobStatusMu.Lock()
154156
allJobStatus = append(allJobStatus, status)
157+
allJobStatusMu.Unlock()
155158
wg.Done()
156159
}()
157160
}
158161
wg.Wait()
159162
countMap := lo.CountValues(allJobStatus)
160163

161-
require.Equal(t, countMap[http.StatusConflict], totalGoRoutines-1)
162-
require.Equal(t, countMap[http.StatusBadRequest], 1)
164+
require.Equal(t, countMap[http.StatusConflict], totalGoRoutines-1, countMap)
165+
require.Equal(t, countMap[http.StatusBadRequest], 1, countMap)
163166
})
164167
}

0 commit comments

Comments
 (0)