@@ -201,15 +201,14 @@ internal class GRPCWebsocketWorker(
201
201
}
202
202
if (shouldRetry) {
203
203
logger.warn(" grpcWebSocket: connection error: $throwable " )
204
- errorBoundary.logException(" grpcWebSocket: connection error" , throwable ? : Exception (" connection closed" ), bypassDedupe = true )
204
+ errorBoundary.logException(" grpcWebSocket: connection error" , throwable ? : Exception (" connection closed" ))
205
205
streamConfigSpecWithBackoff()
206
206
connected = false
207
207
} else {
208
208
logger.warn(" grpcWebSocket: connection error: retry exhausted" )
209
209
errorBoundary.logException(
210
210
" grpcWebSocket: retry exhausted" ,
211
211
Exception (" Remaining retry is $remainingRetries , exception is ${throwable?.message} " ),
212
- bypassDedupe = true ,
213
212
)
214
213
}
215
214
}
@@ -220,7 +219,6 @@ internal class GRPCWebsocketWorker(
220
219
" grpcWebSocket: Reconnected" ,
221
220
Exception (" ${response.lastUpdated} " ),
222
221
extraInfo = " {\" retryAttempt\" : ${retryLimit - remainingRetries} }" ,
223
- bypassDedupe = true ,
224
222
)
225
223
streamingFallback?.cancelBackup()
226
224
}
@@ -235,7 +233,6 @@ internal class GRPCWebsocketWorker(
235
233
" grpcWebSocket: Failed to emit response" ,
236
234
Exception (" ${response.lastUpdated} " ),
237
235
extraInfo = " {\" retryAttempt\" : ${retryLimit - remainingRetries} }" ,
238
- bypassDedupe = true ,
239
236
)
240
237
}
241
238
}
0 commit comments