From c72d1cf009cbe4eec2702ce7edea6b01050ade1b Mon Sep 17 00:00:00 2001 From: Vladi Bilonenko Date: Sun, 7 Apr 2024 21:35:11 +0200 Subject: [PATCH] Fix error handling in Run method --- src/server/snowflakejob/snowflakejob.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/server/snowflakejob/snowflakejob.go b/src/server/snowflakejob/snowflakejob.go index 65dca431..282f85fe 100644 --- a/src/server/snowflakejob/snowflakejob.go +++ b/src/server/snowflakejob/snowflakejob.go @@ -134,9 +134,8 @@ func (j *Job) Run(storageObject storage.StorageObject, connection *proto.Connect j.QueryText, ) if err != nil { - j.Logger.Error().Err(err).Msg("Error starting query execution") j.CancelWithError(err) - return err + return nil // it's ok, since these are query errors } defer rows.Close() csvRows := make(chan []string, 10) //j.TotalRows?