-
Notifications
You must be signed in to change notification settings - Fork 3.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
fix(controller): Fix node status when daemon pod deleted but its children nodes are still running #4683
Conversation
node := d.getTaskNode(taskName) | ||
if node != nil { | ||
return true, true, nil | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can you explain this particular change more? Not sure if we want this
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The case for this code is "explained" in the unittest.
…d. Fixes (argoproj#4652) Signed-off-by: lons <lonsdale8734@gmail.com>
…rgoproj#4665) Signed-off-by: lons <lonsdale8734@gmail.com>
fcc8fb8
to
9c0dbfd
Compare
workflow/controller/operator.go
Outdated
@@ -917,6 +917,7 @@ func (woc *wfOperationCtx) podReconciliation() error { | |||
|
|||
node.Message = "pod deleted" | |||
node.Phase = wfv1.NodeError | |||
node.Daemoned = nil |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
what is this needed for please?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
When daemon pod deleted and Daemoned
flag in node is true, there is a bug that the Deaemoned
flag never removed and the whole workflow will never completed.
@@ -1069,6 +1070,7 @@ func (woc *wfOperationCtx) assessNodeStatus(pod *apiv1.Pod, node *wfv1.NodeStatu | |||
if pod.DeletionTimestamp != nil { | |||
// pod is being terminated | |||
newPhase = wfv1.NodeError | |||
newDaemonStatus = pointer.BoolPtr(false) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
and the purpose of this?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ditto.
…dren nodes are still running (#4683) Signed-off-by: lons <lonsdale8734@gmail.com>
This fix is out on https://github.com/argoproj/argo/releases/tag/v2.12.5 |
Checklist: