@@ -119,23 +119,23 @@ func (c *Controller) Process(ctx context.Context, delivery consumer.Delivery) er
119119 }
120120
121121 switch res .Outcome {
122- case corerequest .TerminationReconciled :
122+ case corerequest .TerminationOutcomeSuccess :
123123 c .logger .Infow ("updated request state" ,
124124 "batch_id" , batch .ID ,
125125 "request_id" , requestID ,
126126 "new_state" , string (res .AfterState ),
127127 )
128- case corerequest .TerminationAlreadyTerminal :
128+ case corerequest .TerminationOutcomeAlreadyInTargetState :
129129 metrics .NamedCounter (c .metricsScope , "process" , "already_reconciled" , 1 )
130- case corerequest .TerminationDiverged :
130+ case corerequest .TerminationOutcomeDiverged :
131131 c .logger .Warnw ("request already in different terminal state, skipping reconcile" ,
132132 "batch_id" , batch .ID ,
133133 "request_id" , requestID ,
134134 "expected_state" , string (requestState ),
135135 "actual_state" , string (res .BeforeState ),
136136 )
137137 metrics .NamedCounter (c .metricsScope , "process" , "terminal_state_divergence" , 1 )
138- case corerequest .TerminationNotFound :
138+ case corerequest .TerminationOutcomeNotFound :
139139 metrics .NamedCounter (c .metricsScope , "process" , "request_store_errors" , 1 )
140140 return fmt .Errorf ("failed to get request %s for batch %s: %w" , requestID , batch .ID , storage .ErrNotFound )
141141 }
0 commit comments