diff --git a/internal/uploads/worker.go b/internal/uploads/worker.go index 6da7b37..8d4b738 100644 --- a/internal/uploads/worker.go +++ b/internal/uploads/worker.go @@ -242,7 +242,7 @@ func (w *Worker) Process(ctx context.Context, job Job) { start := time.Now() if err := w.store.StartTranscribing(ctx, job.UserID, job.UploadID); err != nil { - log.Error("upload: start transcribing", "err", err) + log.Error("upload: start transcribing", "kind", errkind.Of(err)) w.fail(ctx, job, log, domain.UploadErrTranscriptionFailed) return } @@ -279,7 +279,7 @@ func (w *Worker) Process(ctx context.Context, job Job) { wav, err := w.tempWAV() if err != nil { - log.Error("upload: temp wav", "err", err) + log.Error("upload: temp wav", "kind", errkind.Of(err)) abort(domain.UploadErrTranscriptionFailed) return } @@ -322,7 +322,7 @@ func (w *Worker) Process(ctx context.Context, job Job) { tr.Begin("save", 0) if err := w.store.CompleteUpload(ctx, job.UserID, job.UploadID, t); err != nil { - log.Error("upload: store transcript", "err", err) + log.Error("upload: store transcript", "kind", errkind.Of(err)) abort(domain.UploadErrTranscriptionFailed) return } @@ -339,7 +339,7 @@ func (w *Worker) fail(ctx context.Context, job Job, log *slog.Logger, kind domai return } if err := w.store.FailUpload(ctx, job.UserID, job.UploadID, kind); err != nil { - log.Error("upload: record failure", "err", err) + log.Error("upload: record failure", "kind", errkind.Of(err)) } }