Gleipnir/nidus-sync
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Add sublogging for job work for debugging

Browse source
This commit is contained in:
Eli Ribble 2026-04-17 20:25:25 +00:00
parent 75e9d5a621
commit 0e777568fb
No known key found for this signature in database
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
platform/start.go
View file

@ -85,22 +85,25 @@ func addWaitingJobs(ctx context.Context) error {
}
go func() {
for _, job := range jobs {
sublog := log.With().Int32("job", job.ID).Int32("row_id", job.RowID).Str("type", string(job.Type)).Logger()
sublog.Info().Msg("begin restarted background job")
txn, err := db.PGInstance.BobDB.Begin(ctx)
if err != nil {
log.Error().Err(err).Msg("failed begin txn")
sublog.Error().Err(err).Msg("failed begin txn")
return
}
defer txn.Rollback(ctx)
err = handleJob(ctx, txn, job)
if err != nil {
log.Error().Err(err).Msg("failed handle job")
sublog.Error().Err(err).Msg("failed handle job")
return
}
err = job.Delete(ctx, txn)
if err != nil {
log.Error().Err(err).Msg("failed delete job")
sublog.Error().Err(err).Msg("failed delete job")
return
}
sublog.Info().Msg("job complete")
txn.Commit(ctx)
}
}()