Skip to content

Commit 0b88a42

Browse files
committed
bench: pass schema to JobGetAvailable
`BenchmarkDriverRiverPgxV5_Executor` used a pooled executor without setting `Schema` on `JobGetAvailable`, so it could hit default schema and fail with missing `river_job`. Pass `Schema: bundle.schema` in both `JobGetAvailable` benchmark calls so the queries always target the migrated test schema.
1 parent 675e8dd commit 0b88a42

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

riverdriver/riverdrivertest/driver_test.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -441,6 +441,7 @@ func BenchmarkDriverRiverPgxV5_Executor(b *testing.B) {
441441
ClientID: clientID,
442442
MaxToLock: 100,
443443
Queue: river.QueueDefault,
444+
Schema: bundle.schema,
444445
}); err != nil {
445446
b.Fatal(err)
446447
}
@@ -467,6 +468,7 @@ func BenchmarkDriverRiverPgxV5_Executor(b *testing.B) {
467468
ClientID: clientID,
468469
MaxToLock: 100,
469470
Queue: river.QueueDefault,
471+
Schema: bundle.schema,
470472
}); err != nil {
471473
b.Fatal(err)
472474
}

0 commit comments

Comments
 (0)