(ctx context.Context, pod *apiv1.Pod)
| 46 | } |
| 47 | |
| 48 | func (woc *wfOperationCtx) updateAgentPodStatus(ctx context.Context, pod *apiv1.Pod) { |
| 49 | woc.log.Info(ctx, "updateAgentPodStatus") |
| 50 | newPhase, message := assessAgentPodStatus(ctx, pod) |
| 51 | if newPhase == wfv1.NodeFailed || newPhase == wfv1.NodeError { |
| 52 | woc.markTaskSetNodesError(ctx, fmt.Errorf(`agent pod failed with reason:"%s"`, message)) |
| 53 | } |
| 54 | } |
| 55 | |
| 56 | func assessAgentPodStatus(ctx context.Context, pod *apiv1.Pod) (wfv1.NodePhase, string) { |
| 57 | var newPhase wfv1.NodePhase |
no test coverage detected