Method Work

example_resumable_cursor_job_test.go:33–51

(ctx context.Context, job *river.Job[ResumableCursorArgs])

}

func (w *ResumableCursorWorker) Work(ctx context.Context, job *river.Job[ResumableCursorArgs]) error {
	river.ResumableStepCursor(ctx, "process_ids", nil, func(ctx context.Context, cursor ResumableCursor) error {
		for _, id := range job.Args.IDs {
			if id <= cursor.LastProcessedID {
				continue
			}

			fmt.Printf("Processed %d\n", id)

			if err := river.ResumableSetCursor(ctx, ResumableCursor{LastProcessedID: id}); err != nil {
				return err
			}
		}

		return nil
	})

	return nil
}

// Example_resumableCursor demonstrates the use of a resumable cursor step, a
// step that can store arbitrary JSON state to resume a partially completed loop.