Revert "Update retry policy validation with additional conditions (ca…

…dence-workflow#6525)" This reverts commit 1fcd7d5.
sankari165 · Nov 29, 2024 · eca85f6 · eca85f6
1 parent 02d3b7d
commit eca85f6
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 28 deletions.
diff --git a/common/util.go b/common/util.go
@@ -547,12 +547,6 @@ func ValidateRetryPolicy(policy *types.RetryPolicy) error {
 	if policy.GetMaximumAttempts() == 0 && policy.GetExpirationIntervalInSeconds() == 0 {
 		return &types.BadRequestError{Message: "MaximumAttempts and ExpirationIntervalInSeconds are both 0. At least one of them must be specified."}
 	}
-	if policy.GetExpirationIntervalInSeconds() == 0 && policy.GetMaximumAttempts() == 1 {
-		return &types.BadRequestError{Message: "MaximumAttempts set to 1 will not retry since maximum attempts includes the first attempt."}
-	}
-	if policy.GetMaximumAttempts() == 0 && policy.GetExpirationIntervalInSeconds() < policy.GetInitialIntervalInSeconds() {
-		return &types.BadRequestError{Message: "ExpirationIntervalInSeconds less than  InitialIntervalInSeconds  will not retry."}
-	}
 	return nil
 }
 

diff --git a/common/util_test.go b/common/util_test.go
@@ -718,22 +718,29 @@ func TestValidateRetryPolicy_Success(t *testing.T) {
 			InitialIntervalInSeconds:    2,
 			BackoffCoefficient:          1,
 			MaximumIntervalInSeconds:    0,
-			MaximumAttempts:             2,
+			MaximumAttempts:             1,
 			ExpirationIntervalInSeconds: 0,
 		},
 		"ExpirationIntervalInSeconds is no zero": &types.RetryPolicy{
 			InitialIntervalInSeconds:    2,
 			BackoffCoefficient:          1,
 			MaximumIntervalInSeconds:    0,
 			MaximumAttempts:             0,
-			ExpirationIntervalInSeconds: 3,
+			ExpirationIntervalInSeconds: 1,
 		},
 		"MaximumIntervalInSeconds is greater than InitialIntervalInSeconds": &types.RetryPolicy{
 			InitialIntervalInSeconds:    2,
 			BackoffCoefficient:          1,
 			MaximumIntervalInSeconds:    0,
 			MaximumAttempts:             0,
-			ExpirationIntervalInSeconds: 3,
+			ExpirationIntervalInSeconds: 1,
+		},
+		"MaximumIntervalInSeconds equals InitialIntervalInSeconds": &types.RetryPolicy{
+			InitialIntervalInSeconds:    2,
+			BackoffCoefficient:          1,
+			MaximumIntervalInSeconds:    2,
+			MaximumAttempts:             0,
+			ExpirationIntervalInSeconds: 1,
 		},
 	} {
 		t.Run(name, func(t *testing.T) {
@@ -791,25 +798,6 @@ func TestValidateRetryPolicy_Error(t *testing.T) {
 			},
 			wantErr: &types.BadRequestError{Message: "MaximumAttempts cannot be less than 0 on retry policy."},
 		},
-		"MaximumAttempts equals 1": {
-			policy: &types.RetryPolicy{
-				InitialIntervalInSeconds: 2,
-				BackoffCoefficient:       1,
-				MaximumIntervalInSeconds: 0,
-				MaximumAttempts:          1,
-			},
-			wantErr: &types.BadRequestError{Message: "MaximumAttempts set to 1 will not retry since maximum attempts includes the first attempt."},
-		},
-		"ExpirationIntervalInSeconds less than InitialIntervalInSeconds": {
-			policy: &types.RetryPolicy{
-				InitialIntervalInSeconds:    2,
-				BackoffCoefficient:          1,
-				MaximumIntervalInSeconds:    0,
-				MaximumAttempts:             0,
-				ExpirationIntervalInSeconds: 1,
-			},
-			wantErr: &types.BadRequestError{Message: "ExpirationIntervalInSeconds less than  InitialIntervalInSeconds  will not retry."},
-		},
 		"ExpirationIntervalInSeconds equals -1": {
 			policy: &types.RetryPolicy{
 				InitialIntervalInSeconds:    2,