Skip to content

Commit 9cecf61

Browse files
committed
Adding handling for ConditionTypeRecoverable
1 parent 60cbf52 commit 9cecf61

File tree

1 file changed

+16
-17
lines changed

1 file changed

+16
-17
lines changed

templates/pkg/resource/sdk.go.tpl

Lines changed: 16 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -164,16 +164,15 @@ func (rm *resourceManager) updateConditions (
164164
165165
// Terminal condition
166166
var terminalCondition *ackv1alpha1.Condition = nil
167-
var nonTerminalCondition *ackv1alpha1.Condition = nil
167+
var recoverableCondition *ackv1alpha1.Condition = nil
168168
for _, condition := range ko.Status.Conditions {
169-
// If terminal condition exists, other errors will
170-
// will not be reported
171169
if condition.Type == ackv1alpha1.ConditionTypeTerminal {
172170
terminalCondition = condition
173171
break
174172
}
175-
if condition.Type == ackv1alpha1.ConditionTypeNonTerminal {
176-
nonTerminalCondition = condition
173+
// Continue to check if Terminal Condition exists
174+
if condition.Type == ackv1alpha1.ConditionTypeRecoverable {
175+
recoverableCondition = condition
177176
}
178177
}
179178

@@ -194,37 +193,37 @@ func (rm *resourceManager) updateConditions (
194193
terminalCondition.Status = corev1.ConditionFalse
195194
terminalCondition.Message = nil
196195
}
197-
// Handling NonTerminal Conditions
196+
// Handling Recoverable Conditions
198197
if err != nil {
199-
if nonTerminalCondition == nil {
198+
if recoverableCondition == nil {
200199
// Add a new Condition containing a non-terminal error
201-
nonTerminalCondition = &ackv1alpha1.Condition{
202-
Type: ackv1alpha1.ConditionTypeNonTerminal,
200+
recoverableCondition = &ackv1alpha1.Condition{
201+
Type: ackv1alpha1.ConditionTypeRecoverable,
203202
}
204-
ko.Status.Conditions = append(ko.Status.Conditions, nonTerminalCondition)
203+
ko.Status.Conditions = append(ko.Status.Conditions, recoverableCondition)
205204
}
206-
nonTerminalCondition.Status = corev1.ConditionTrue
205+
recoverableCondition.Status = corev1.ConditionTrue
207206
awsErr, _ := ackerr.AWSError(err)
208207
errorMessage := "Unknown Error"
209208
if awsErr != nil {
210209
errorMessage = awsErr.Message()
211210
}
212-
nonTerminalCondition.Message = &errorMessage
213-
} else if nonTerminalCondition != nil {
214-
nonTerminalCondition.Status = corev1.ConditionFalse
215-
nonTerminalCondition.Message = nil
211+
recoverableCondition.Message = &errorMessage
212+
} else if recoverableCondition != nil {
213+
recoverableCondition.Status = corev1.ConditionFalse
214+
recoverableCondition.Message = nil
216215
}
217216
}
218217

219218

220219
{{- if $updateConditionsCustomMethodName := .CRD.UpdateConditionsCustomMethodName }}
221220
// custom update conditions
222221
customUpdate := rm.{{ $updateConditionsCustomMethodName }}(ko, r, err)
223-
if terminalCondition != nil || nonTerminalCondition != nil || customUpdate {
222+
if terminalCondition != nil || recoverableCondition != nil || customUpdate {
224223
return &resource{ko}, true // updated
225224
}
226225
{{- else }}
227-
if terminalCondition != nil || nonTerminalCondition != nil {
226+
if terminalCondition != nil || recoverableCondition != nil {
228227
return &resource{ko}, true // updated
229228
}
230229
{{- end }}

0 commit comments

Comments
 (0)