handling of skipped event

ayu-devtron · ayu-devtron · commit 3838e387266f · 2025-02-12T15:11:53.000+05:30
diff --git a/pkg/pipeline/workflowStatus/WorkflowStageStatusService.go b/pkg/pipeline/workflowStatus/WorkflowStageStatusService.go
@@ -134,7 +134,7 @@ func (impl *WorkFlowStageStatusServiceImpl) updatePodStages(currentWorkflowStage
 					stage.Status = bean2.WORKFLOW_STAGE_STATUS_SUCCEEDED
 					stage.EndTime = time.Now().Format(bean3.LayoutRFC3339)
 				}
-			case string(v1alpha1.NodeFailed), string(v1alpha1.NodeError):
+			case string(v1alpha1.NodeFailed), string(v1alpha1.NodeError), string(v1alpha1.NodeSkipped):
 				if stage.Status == bean2.WORKFLOW_STAGE_STATUS_RUNNING ||
 					stage.Status == bean2.WORKFLOW_STAGE_STATUS_NOT_STARTED ||
 					stage.Status == bean2.WORKFLOW_STAGE_STATUS_UNKNOWN {

Original file line number	Diff line number	Diff line change
`@@ -134,7 +134,7 @@ func (impl *WorkFlowStageStatusServiceImpl) updatePodStages(currentWorkflowStage`
`134`	`134`	`stage.Status = bean2.WORKFLOW_STAGE_STATUS_SUCCEEDED`
`135`	`135`	`stage.EndTime = time.Now().Format(bean3.LayoutRFC3339)`
`136`	`136`	`}`
`137`		`- case string(v1alpha1.NodeFailed), string(v1alpha1.NodeError):`
	`137`	`+ case string(v1alpha1.NodeFailed), string(v1alpha1.NodeError), string(v1alpha1.NodeSkipped):`
`138`	`138`	`if stage.Status == bean2.WORKFLOW_STAGE_STATUS_RUNNING \|\|`
`139`	`139`	`stage.Status == bean2.WORKFLOW_STAGE_STATUS_NOT_STARTED \|\|`
`140`	`140`	`stage.Status == bean2.WORKFLOW_STAGE_STATUS_UNKNOWN {`