| 13 | ) |
| 14 | |
| 15 | func getWfOperationCtx() *wfOperationCtx { |
| 16 | return &wfOperationCtx{ |
| 17 | wf: &v1alpha1.Workflow{ |
| 18 | ObjectMeta: metav1.ObjectMeta{ |
| 19 | Name: "1", |
| 20 | Namespace: "default", |
| 21 | }, |
| 22 | Status: v1alpha1.WorkflowStatus{ |
| 23 | Nodes: map[string]v1alpha1.NodeStatus{ |
| 24 | "1": {Type: v1alpha1.NodeTypePod, Phase: v1alpha1.NodeSucceeded, BoundaryID: "1"}, |
| 25 | "2": {Type: v1alpha1.NodeTypePod, Phase: v1alpha1.NodeFailed, BoundaryID: "1"}, |
| 26 | "3": {Type: v1alpha1.NodeTypeSteps, Phase: v1alpha1.NodeFailed, BoundaryID: "1"}, |
| 27 | "4": {Type: v1alpha1.NodeTypeDAG, Phase: v1alpha1.NodeError, BoundaryID: "1"}, |
| 28 | "5": {ID: "1", Type: v1alpha1.NodeTypePod, Phase: v1alpha1.NodeRunning, BoundaryID: "1"}, |
| 29 | "5a": {ID: "2", Type: v1alpha1.NodeTypePod, Phase: v1alpha1.NodePending, BoundaryID: "1", SynchronizationStatus: &v1alpha1.NodeSynchronizationStatus{Waiting: "yes"}}, |
| 30 | "6": {ID: "1", Type: v1alpha1.NodeTypePod, Phase: v1alpha1.NodePending, BoundaryID: "1"}, |
| 31 | "7": {ID: "2", Type: v1alpha1.NodeTypeSteps, Phase: v1alpha1.NodeRunning, BoundaryID: "1"}, |
| 32 | "8": {ID: "1", Type: v1alpha1.NodeTypeDAG, Phase: v1alpha1.NodePending, BoundaryID: "1"}, |
| 33 | |
| 34 | "9": {Type: v1alpha1.NodeTypeSteps, Phase: v1alpha1.NodeFailed, BoundaryID: "2"}, |
| 35 | "10": {Type: v1alpha1.NodeTypeDAG, Phase: v1alpha1.NodeError, BoundaryID: "2"}, |
| 36 | "11": {ID: "1", Type: v1alpha1.NodeTypePod, Phase: v1alpha1.NodeRunning, BoundaryID: "2"}, |
| 37 | "12": {ID: "2", Type: v1alpha1.NodeTypePod, Phase: v1alpha1.NodePending, BoundaryID: "2"}, |
| 38 | }, |
| 39 | }, |
| 40 | }, |
| 41 | } |
| 42 | } |
| 43 | |
| 44 | var podStr = `apiVersion: v1 |
| 45 | kind: Pod |