(ctx context.Context, t testingT, driver TDriver, expectedJob TArgs, opts *RequireInsertedOpts)
| 217 | } |
| 218 | |
| 219 | func requireNotInserted[TDriver riverdriver.Driver[TTx], TTx any, TArgs river.JobArgs](ctx context.Context, t testingT, driver TDriver, expectedJob TArgs, opts *RequireInsertedOpts) { |
| 220 | t.Helper() |
| 221 | err := requireNotInsertedErr[TDriver](ctx, t, driver.GetExecutor(), expectedJob, opts) |
| 222 | if err != nil { |
| 223 | failuref(t, "Internal failure: %s", err) |
| 224 | } |
| 225 | } |
| 226 | |
| 227 | // RequireNotInsertedTx is a test helper that verifies that a job of the given |
| 228 | // kind was not inserted for work, failing the test if one was. |
searching dependent graphs…