Merge pull request #315 from GoogleCloudPlatform/issue314

feat: adds conditional failure policy #314
GoogleCloudPlatform · Dec 10, 2024 · 47dc5ad · 47dc5ad
2 parents 82435d9 + 2271f90
commit 47dc5ad
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/internal/client/integrations/integrations.go b/internal/client/integrations/integrations.go
@@ -190,6 +190,7 @@ type taskconfig struct {
 	SuccessPolicy                *successPolicy            `json:"successPolicy,omitempty"`
 	TaskTemplate                 string                    `json:"taskTemplate,omitempty"`
 	FailurePolicy                *failurePolicy            `json:"failurePolicy,omitempty"`
+	ConditionalFailurePolicies   *conditionalFailurePolicy `json:"conditionalFailurePolicies,omitempty"`
 	SynchronousCallFailurePolicy *failurePolicy            `json:"synchronousCallFailurePolicy,omitempty"`
 	ErrorCatcherId               string                    `json:"errorCatcherId,omitempty"`
 	ExternalTaskType             string                    `json:"externalTaskType,omitempty"`
@@ -244,6 +245,7 @@ type failurePolicy struct {
 	RetryStrategy string `json:"retryStrategy,omitempty"`
 	MaxRetries    int    `json:"maxRetries,omitempty"`
 	IntervalTime  string `json:"intervalTime,omitempty"`
+	Condition     string `json:"condition,omitempty"`
 }
 
 type cloudSchedulerConfig struct {
@@ -260,6 +262,11 @@ type integrationConnection struct {
 	CustomConnection bool
 }
 
+type conditionalFailurePolicy struct {
+	FailurePolicies      []failurePolicy `json:"failurePolicies,omitempty"`
+	DefaultFailurePolicy *failurePolicy  `json:"defaultFailurePolicy,omitempty"`
+}
+
 // CreateVersion
 func CreateVersion(name string, content []byte, overridesContent []byte, snapshot string,
 	userlabel string, grantPermission bool,