Skip to content

Commit dcde1ee

Browse files
committed
fix(stub): correct how we are getting db in migration
1 parent 012cf39 commit dcde1ee

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

stubs/migration.stub

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,14 +8,14 @@ import { QueueSchemaService } from '@boringnode/queue'
88

99
export default class extends BaseSchema {
1010
async up() {
11-
const schemaService = new QueueSchemaService(this.db.connection().getWriteClient())
11+
const schemaService = new QueueSchemaService(this.db.getWriteClient())
1212

1313
await schemaService.createJobsTable()
1414
await schemaService.createSchedulesTable()
1515
}
1616

1717
async down() {
18-
const schemaService = new QueueSchemaService(this.db.connection().getWriteClient())
18+
const schemaService = new QueueSchemaService(this.db.getWriteClient())
1919

2020
await schemaService.dropSchedulesTable()
2121
await schemaService.dropJobsTable()

0 commit comments

Comments
 (0)