Skip to content

Commit

Permalink
e2e
Browse files Browse the repository at this point in the history
Signed-off-by: Julie Vogelman <[email protected]>
  • Loading branch information
juliev0 committed Sep 19, 2024
1 parent 88e5002 commit 08a3628
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion tests/e2e/pipeline.go
Original file line number Diff line number Diff line change
Expand Up @@ -97,12 +97,13 @@ func verifyPipelineRunning(namespace string, pipelineName string, numVertices in

func verifyPipelinePaused(namespace string, pipelineName string) {

document("Verify that child Pipeline is paused")
document("Verify that Pipeline Rollout condition is Pausing/Paused")
verifyPipelineStatusEventually(Namespace, pipelineName, func(spec numaflowv1.PipelineSpec, status kubernetes.GenericStatus) bool {
pauseCondition := getRolloutCondition(status.Conditions, apiv1.ConditionPipelinePausingOrPaused)
return pauseCondition == metav1.ConditionTrue
})

document("Verify that Pipeline is paused")
verifyPipelineStatusEventually(Namespace, pipelineName,
func(retrievedPipelineSpec numaflowv1.PipelineSpec, retrievedPipelineStatus kubernetes.GenericStatus) bool {
return retrievedPipelineStatus.Phase == string(numaflowv1.PipelinePhasePaused)
Expand Down

0 comments on commit 08a3628

Please sign in to comment.