@@ -31,13 +31,13 @@ func NewService(db storage.BrokerStorage, dryRun bool, performDeletion bool, bat
3131 }
3232}
3333
34- func (s * Service ) Run () (error , int , int ) {
34+ func (s * Service ) Run () (int , int , error ) {
3535 l := slog .New (slog .NewJSONHandler (os .Stdout , nil ))
3636
3737 instanceIDs , err := s .instances .ListDeletedInstanceIDs (s .batchSize )
3838 if err != nil {
3939 slog .Error (fmt .Sprintf ("Unable to get instance IDs: %s" , err .Error ()))
40- return err , 0 , 0
40+ return 0 , 0 , err
4141 }
4242 l .Info (fmt .Sprintf ("Got %d instance IDs to process" , len (instanceIDs )))
4343
@@ -51,10 +51,10 @@ func (s *Service) Run() (error, int, int) {
5151 if errInstance == nil {
5252 logger .Error (fmt .Sprintf ("the instance (createdAt: %s, planName: %s) still exists, aborting the process" ,
5353 instance .InstanceID , instance .CreatedAt ))
54- return fmt .Errorf ("instance exists" ), numberOfInstancesProcessed , numberOfOperationsDeleted
54+ return numberOfInstancesProcessed , numberOfOperationsDeleted , fmt .Errorf ("instance exists" )
5555 }
5656 if ! dberr .IsNotFound (errInstance ) {
57- return errInstance , numberOfInstancesProcessed , numberOfOperationsDeleted
57+ return numberOfInstancesProcessed , numberOfOperationsDeleted , errInstance
5858 }
5959
6060 operations , err := s .operations .ListOperationsByInstanceID (instanceId )
@@ -110,5 +110,5 @@ func (s *Service) Run() (error, int, int) {
110110 numberOfInstancesProcessed ++
111111 }
112112
113- return nil , numberOfInstancesProcessed , numberOfOperationsDeleted
113+ return numberOfInstancesProcessed , numberOfOperationsDeleted , nil
114114}
0 commit comments