(pod *apiv1.Pod)
| 1297 | } |
| 1298 | |
| 1299 | func (woc *wfOperationCtx) nodeID(pod *apiv1.Pod) string { |
| 1300 | nodeID, ok := pod.Annotations[common.AnnotationKeyNodeID] |
| 1301 | if !ok { |
| 1302 | nodeID = woc.wf.NodeID(pod.Annotations[common.AnnotationKeyNodeName]) |
| 1303 | } |
| 1304 | return nodeID |
| 1305 | } |
| 1306 | |
| 1307 | func recentlyStarted(ctx context.Context, node wfv1.NodeStatus) bool { |
| 1308 | return time.Since(node.StartedAt.Time) <= envutil.LookupEnvDurationOr(ctx, "RECENTLY_STARTED_POD_DURATION", 10*time.Second) |