add job kind to job executor logging (#348)

elee1766 · web-flow · commit 4def8bc95ed9 · 2024-05-09T22:02:42.000-07:00
diff --git a/job_executor.go b/job_executor.go
@@ -247,6 +247,7 @@ func (e *jobExecutor) reportResult(ctx context.Context, res *jobExecutorResult)
 	if res.Err != nil && errors.As(res.Err, &snoozeErr) {
 		e.Logger.InfoContext(ctx, e.Name+": Job snoozed",
 			slog.Int64("job_id", e.JobRow.ID),
+		        slog.String("job_kind", e.JobRow.Kind),
 			slog.Duration("duration", snoozeErr.duration),
 		)
 		nextAttemptScheduledAt := time.Now().Add(snoozeErr.duration)
@@ -293,6 +294,7 @@ func (e *jobExecutor) reportError(ctx context.Context, res *jobExecutorResult) {
 	logAttrs := []any{
 		slog.String("error", res.ErrorStr()),
 		slog.Int64("job_id", e.JobRow.ID),
+		slog.String("job_kind", e.JobRow.Kind),
 	}
 
 	switch {

Original file line number	Diff line number	Diff line change
`@@ -247,6 +247,7 @@ func (e jobExecutor) reportResult(ctx context.Context, res jobExecutorResult)`
`247`	`247`	`if res.Err != nil && errors.As(res.Err, &snoozeErr) {`
`248`	`248`	`e.Logger.InfoContext(ctx, e.Name+": Job snoozed",`
`249`	`249`	`slog.Int64("job_id", e.JobRow.ID),`
	`250`	`+ slog.String("job_kind", e.JobRow.Kind),`
`250`	`251`	`slog.Duration("duration", snoozeErr.duration),`
`251`	`252`	`)`
`252`	`253`	`nextAttemptScheduledAt := time.Now().Add(snoozeErr.duration)`
`@@ -293,6 +294,7 @@ func (e jobExecutor) reportError(ctx context.Context, res jobExecutorResult) {`
`293`	`294`	`logAttrs := []any{`
`294`	`295`	`slog.String("error", res.ErrorStr()),`
`295`	`296`	`slog.Int64("job_id", e.JobRow.ID),`
	`297`	`+ slog.String("job_kind", e.JobRow.Kind),`
`296`	`298`	`}`
`297`	`299`
`298`	`300`	`switch {`