Skip to content

Commit 385d478

Browse files
authored
fix(dbm): add table lock await (#71)
* add: await * bump: version
1 parent f27e7e1 commit 385d478

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

meerkat-dbm/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@devrev/meerkat-dbm",
3-
"version": "0.0.161",
3+
"version": "0.0.162",
44
"dependencies": {
55
"tslib": "^2.3.0",
66
"@duckdb/duckdb-wasm": "^1.28.0",

meerkat-dbm/src/dbm/dbm.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -264,7 +264,9 @@ export class DBM {
264264
/**
265265
* Lock the tables
266266
*/
267-
this.lockTables(this.currentQueryItem.tables.map((table) => table.name));
267+
await this.lockTables(
268+
this.currentQueryItem.tables.map((table) => table.name)
269+
);
268270

269271
const startTime = Date.now();
270272
this.logger.debug(
@@ -313,7 +315,7 @@ export class DBM {
313315
/**
314316
* Unlock the tables
315317
*/
316-
this.unlockTables(
318+
await this.unlockTables(
317319
this.currentQueryItem.tables.map((table) => table.name)
318320
);
319321
}

0 commit comments

Comments
 (0)