(ctx context.Context, tb testing.TB, exec riverdriver.Executor, opts *JobOpts)
| 40 | } |
| 41 | |
| 42 | func Job(ctx context.Context, tb testing.TB, exec riverdriver.Executor, opts *JobOpts) *rivertype.JobRow { |
| 43 | tb.Helper() |
| 44 | |
| 45 | job, err := exec.JobInsertFull(ctx, Job_Build(tb, opts)) |
| 46 | require.NoError(tb, err) |
| 47 | |
| 48 | return job |
| 49 | } |
| 50 | |
| 51 | func Job_Build(tb testing.TB, opts *JobOpts) *riverdriver.JobInsertFullParams { |
| 52 | tb.Helper() |