From 478b92433ff0afa555a129babf1526718c714f86 Mon Sep 17 00:00:00 2001 From: Derek Horton Date: Tue, 27 Feb 2024 12:51:22 -0600 Subject: [PATCH] Check the response from the database query sooner in the response-consumer --- internal/response-consumer/handler.go | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/internal/response-consumer/handler.go b/internal/response-consumer/handler.go index 509d5437..371d5c62 100644 --- a/internal/response-consumer/handler.go +++ b/internal/response-consumer/handler.go @@ -83,6 +83,15 @@ func (this *handler) onMessage(ctx context.Context, msg *k.Message) { selectResult := baseQuery.Select("id", "status", "response_full").First(&run) + if selectResult.Error != nil { + if errors.Is(selectResult.Error, gorm.ErrRecordNotFound) { + return nil + } + + utils.GetLogFromContext(ctx).Errorw("Error fetching run from db", "error", selectResult.Error) + return selectResult.Error + } + if requestType == satMessageHeaderValue { satellite.SortSatEvents(value.SatEvents) @@ -101,15 +110,6 @@ func (this *handler) onMessage(ctx context.Context, msg *k.Message) { eventsSerialized = utils.MustMarshal(value.RunnerEvents) } - if selectResult.Error != nil { - if errors.Is(selectResult.Error, gorm.ErrRecordNotFound) { - return nil - } - - utils.GetLogFromContext(ctx).Errorw("Error fetching run from db", "error", selectResult.Error) - return selectResult.Error - } - toUpdate := db.Run{ Status: status, Events: eventsSerialized,