From 0e777568fb503073b09738ac0aafb4bd8bc36c1c Mon Sep 17 00:00:00 2001
From: Eli Ribble <eli@gleipnir.technology>
Date: Fri, 17 Apr 2026 20:25:25 +0000
Subject: [PATCH] Add sublogging for job work for debugging

---
 platform/start.go | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/platform/start.go b/platform/start.go
index e1784c68..a2631f5f 100644
--- a/platform/start.go
+++ b/platform/start.go
@@ -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)
 		}
 	}()