Method Work

rivertest/worker.go:104–112

Work inserts a job with the provided arguments and optional insert options, then works it. The transaction is used for all work-related database operations so that the caller can easily roll back at the end of the test to maintain a clean database state. The returned WorkResult contains the updated

(ctx context.Context, tb testing.TB, tx TTx, args T, opts *river.InsertOpts)

// The returned error only reflects _real_ errors and does not include
// explicitly returned snooze or cancel errors from the worker.
func (w *Worker[T, TTx]) Work(ctx context.Context, tb testing.TB, tx TTx, args T, opts *river.InsertOpts) (*WorkResult, error) {
	tb.Helper()

	job, err := w.insertJob(ctx, tb, tx, args, opts)
	if err != nil {
		return nil, fmt.Errorf("failed to insert job: %w", err)
	}
	return w.WorkJob(ctx, tb, tx, job)
}

// WorkJob works an existing job already in the database. The job must be
// inserted using external logic prior to calling this method. The transaction