summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-07-26 21:20:12 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-07-26 21:20:12 +0200
commitc9c2e127a921886073c14c228b8c9b427f216b6b (patch)
tree7e8b97b72897426795ba49c31cc3cdd238158c73
parent02a30adac0f92366ef9e6118581e39602b6d0d39 (diff)
downloadprocessor-c9c2e127a921886073c14c228b8c9b427f216b6b.tar.gz
processor-c9c2e127a921886073c14c228b8c9b427f216b6b.zip
fix deadlock catching?release/2.14.0
-rw-r--r--worker.js2
1 files changed, 1 insertions, 1 deletions
diff --git a/worker.js b/worker.js
index f68b848..4647d43 100644
--- a/worker.js
+++ b/worker.js
@@ -284,7 +284,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
{ persistent: true }));
} catch (err) {
if (err instanceof Seq.TimeoutError ||
- (err instanceof Seq.DatabaseError && err.code == 1213)) {
+ (err instanceof Seq.DatabaseError && err.errno == 1213)) {
// deadlocks / timeout
logger.error("SQL error", err);
await Promise.map(msgs, async (m) =>