File tree Expand file tree Collapse file tree 1 file changed +2
-7
lines changed Expand file tree Collapse file tree 1 file changed +2
-7
lines changed Original file line number Diff line number Diff line change @@ -33,7 +33,7 @@ const SECURE_CONNECTION = ["1", "true"].includes(process.env.SECURE_CONNECTION ?
3333const TASK_RUN_COMPLETED_WITH_ACK_TIMEOUT_MS =
3434 parseInt ( process . env . TASK_RUN_COMPLETED_WITH_ACK_TIMEOUT_MS || "" ) || 30_000 ;
3535const TASK_RUN_COMPLETED_WITH_ACK_MAX_RETRIES =
36- parseInt ( process . env . TASK_RUN_COMPLETED_WITH_ACK_MAX_RETRIES || "" ) || 5 ;
36+ parseInt ( process . env . TASK_RUN_COMPLETED_WITH_ACK_MAX_RETRIES || "" ) || 7 ;
3737
3838const logger = new SimpleStructuredLogger ( "coordinator" , undefined , { nodeName : NODE_NAME } ) ;
3939const chaosMonkey = new ChaosMonkey (
@@ -783,12 +783,7 @@ class TaskCoordinator {
783783 delay,
784784 elapsedMs,
785785 } ) ;
786-
787- const success = await sendCompletionWithAck ( ) ;
788-
789- if ( ! success ) {
790- throw new Error ( "Failed to send completion with ack" ) ;
791- }
786+ return await sendCompletionWithAck ( ) ;
792787 }
793788 ) ;
794789
You can’t perform that action at this time.
0 commit comments