Skip to content

Commit 1bd50fa

Browse files
marktermsarabala1979
authored andcommitted
Added retry around RuntimeExecutor.Wait call when waiting for main container completion (argoproj#1597)
1 parent 0393427 commit 1bd50fa

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

workflow/executor/executor.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -888,7 +888,14 @@ func (we *WorkflowExecutor) Wait() error {
888888
annotationUpdatesCh := we.monitorAnnotations(ctx)
889889
go we.monitorDeadline(ctx, annotationUpdatesCh)
890890

891-
err = we.RuntimeExecutor.Wait(mainContainerID)
891+
_ = wait.ExponentialBackoff(retry.DefaultRetry, func() (bool, error) {
892+
err = we.RuntimeExecutor.Wait(mainContainerID)
893+
if err != nil {
894+
log.Warnf("Failed to wait for container id '%s': %v", mainContainerID, err)
895+
return false, err
896+
}
897+
return true, nil
898+
})
892899
if err != nil {
893900
return err
894901
}

0 commit comments

Comments
 (0)