@@ -322,13 +322,13 @@ func (m *Messenger) Consumer(targetName string) {
322322 case "deploytarget:restic:backup:restore" , "kubernetes:restic:backup:restore" :
323323 v1alpha1 , v1 , err := helpers .K8UPVersions (ctx , m .Client )
324324 if err != nil {
325- //@TODO: send msg back to lagoon and update task to failed?
326- message .Ack (false ) // ack to remove from queue
325+ // @TODO: send msg back to lagoon and update task to failed?
326+ _ = message .Ack (false ) // ack to remove from queue
327327 return
328328 }
329329 if ! v1alpha1 && ! v1 {
330330 // k8up not installed
331- message .Ack (false ) // ack to remove from queue
331+ _ = message .Ack (false ) // ack to remove from queue
332332 return
333333 }
334334 opLog .Info (
@@ -354,13 +354,13 @@ func (m *Messenger) Consumer(targetName string) {
354354 case "deploytarget:restic:cancel:restore" :
355355 v1alpha1 , v1 , err := helpers .K8UPVersions (ctx , m .Client )
356356 if err != nil {
357- //@TODO: send msg back to lagoon and update task to failed?
358- message .Ack (false ) // ack to remove from queue
357+ // @TODO: send msg back to lagoon and update task to failed?
358+ _ = message .Ack (false ) // ack to remove from queue
359359 return
360360 }
361361 if ! v1alpha1 && ! v1 {
362362 // k8up not installed
363- message .Ack (false ) // ack to remove from queue
363+ _ = message .Ack (false ) // ack to remove from queue
364364 return
365365 }
366366 // if this is a request to cancel a restore attempt
@@ -380,8 +380,8 @@ func (m *Messenger) Consumer(targetName string) {
380380 jobSpec .Environment .Name ,
381381 ),
382382 )
383- //@TODO: send msg back to lagoon and update task to failed?
384- message .Ack (false ) // ack to remove from queue
383+ // @TODO: send msg back to lagoon and update task to failed?
384+ _ = message .Ack (false ) // ack to remove from queue
385385 return
386386 }
387387 case "deploytarget:route:migrate" , "kubernetes:route:migrate" , "openshift:route:migrate" :
0 commit comments