This commit is contained in:
parent
dc853213b8
commit
5dd7c7e3bd
|
@ -108,8 +108,16 @@ module.exports = Self => {
|
||||||
|
|
||||||
return cleanCount;
|
return cleanCount;
|
||||||
} finally {
|
} finally {
|
||||||
await Self.rawSql(`DO RELEASE_LOCK(?)`, [lockName], opts);
|
try {
|
||||||
await tx.rollback();
|
await Self.rawSql(`DO RELEASE_LOCK(?)`, [lockName], opts);
|
||||||
|
} catch (err) {
|
||||||
|
console.error(err);
|
||||||
|
}
|
||||||
|
try {
|
||||||
|
await tx.rollback();
|
||||||
|
} catch (err) {
|
||||||
|
console.error(err);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
|
|
Loading…
Reference in New Issue