mirror/phylum
1
0
Fork 0
mirror of https://codeberg.org/shroff/phylum.git synced 2026-01-07 04:00:17 -06:00
Code Issues Packages Projects Releases Wiki Activity

[server][steve] Tweak logging

Browse Source
This commit is contained in:
Abhishek Shroff
2025-06-16 11:05:17 +05:30
parent 3011f4af29
commit ea7f79c332
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
server/internal/steve/steve.go
View File

@@ -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(),