From ea7f79c33284249ad2d010f4c9be1334c24ab94e Mon Sep 17 00:00:00 2001 From: Abhishek Shroff Date: Mon, 16 Jun 2025 11:05:17 +0530 Subject: [PATCH] [server][steve] Tweak logging --- server/internal/steve/steve.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/server/internal/steve/steve.go b/server/internal/steve/steve.go index 5a4d410a..c7953216 100644 --- a/server/internal/steve/steve.go +++ b/server/internal/steve/steve.go @@ -197,6 +197,11 @@ func (c *Client) execute(ctx context.Context, info *JobInfo) { c.recordError(info, err) } else { updateJobStatus(c.db, info.ID, JobStatusCompleted) + c.logger. + Trace(). + Int32("id", info.ID). + Int("attempt", info.Attempt). + Msg("Job Completed") } }() } @@ -207,8 +212,8 @@ func (c *Client) recordError(info *JobInfo, err error) error { Warn(). Err(err). Int32("id", info.ID). - Int("attempt", info.Attempt+1). - Msg("Error executing job") + Int("attempt", info.Attempt). + Msg("Job Error") return updateJobStatusError( c.db, info.ID, @@ -232,6 +237,7 @@ func (c *Client) InsertJobs(db db.Handler, args []JobArgs) error { if err != nil { return err } + c.logger.Trace().Str("kind", a.Kind()).Str("args", string(encodedArgs)).Msg("Job Enqueued") params[i] = insertJobParams{ Kind: a.Kind(),