Job cancellation doesn't work in database/sql driver #630

const SortJobKind = "sort"
type SortArgs struct {
 Strings []string `json:"strings"`
}
func (SortArgs) Kind() string {
 return SortJobKind
}
type SortWorker struct {
 river.WorkerDefaults[SortArgs]
}
func (w *SortWorker) Work(ctx context.Context, job *river.Job[SortArgs]) error {
 log.Printf("STARTING: %d", job.ID)
 select {
 case <-ctx.Done():
 log.Printf("CANCELLED: %d", job.ID)
 return ctx.Err()
 case <-time.After(20 * time.Second):
 log.Printf("WILL DO: %d", job.ID)
 }
 items := job.Args.Strings
 sort.Strings(items)
 log.Printf("RESULT: %+v\n", items)
 return nil
}

{
 "cancel_attempted_at": "2024年10月02日T....."
}