@@ -195,7 +195,7 @@ function getWorkerQueue() {
195
195
} ,
196
196
deliverHttpSourceRequest : {
197
197
priority : 1 , // smaller number = higher priority
198
- maxAttempts : 25 ,
198
+ maxAttempts : 14 ,
199
199
handler : async ( payload , job ) => {
200
200
const service = new DeliverHttpSourceRequestService ( ) ;
201
201
@@ -204,7 +204,7 @@ function getWorkerQueue() {
204
204
} ,
205
205
startRun : {
206
206
priority : 0 , // smaller number = higher priority
207
- maxAttempts : 8 ,
207
+ maxAttempts : 4 ,
208
208
handler : async ( payload , job ) => {
209
209
const service = new StartRunService ( ) ;
210
210
@@ -231,6 +231,7 @@ function getWorkerQueue() {
231
231
} ,
232
232
indexEndpoint : {
233
233
priority : 1 , // smaller number = higher priority
234
+ maxAttempts : 7 ,
234
235
handler : async ( payload , job ) => {
235
236
const service = new IndexEndpointService ( ) ;
236
237
@@ -239,6 +240,7 @@ function getWorkerQueue() {
239
240
} ,
240
241
deliverEvent : {
241
242
priority : 0 , // smaller number = higher priority
243
+ maxAttempts : 5 ,
242
244
handler : async ( payload , job ) => {
243
245
const service = new DeliverEventService ( ) ;
244
246
@@ -248,7 +250,7 @@ function getWorkerQueue() {
248
250
refreshOAuthToken : {
249
251
priority : 8 , // smaller number = higher priority
250
252
queueName : "internal-queue" ,
251
- maxAttempts : 10 ,
253
+ maxAttempts : 7 ,
252
254
handler : async ( payload , job ) => {
253
255
await integrationAuthRepository . refreshConnection ( {
254
256
connectionId : payload . connectionId ,
@@ -286,7 +288,7 @@ function getExecutionWorkerQueue() {
286
288
} ,
287
289
performRunExecutionV2 : {
288
290
priority : 0 , // smaller number = higher priority
289
- maxAttempts : 18 ,
291
+ maxAttempts : 12 ,
290
292
handler : async ( payload , job ) => {
291
293
const service = new PerformRunExecutionV2Service ( ) ;
292
294
0 commit comments