From cf3e9b680a315dfac5ff8571799ba700754dbe2d Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Fri, 7 Apr 2017 23:52:11 +0200
Subject: attempt to fix race condition

---
 worker.js | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'worker.js')

diff --git a/worker.js b/worker.js
index 1772db6..1b72e36 100644
--- a/worker.js
+++ b/worker.js
@@ -55,7 +55,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI,
 
         // fill queue until batchsize or idle
         if (timer === undefined)
-            timer = setTimeout(process, IDLE_TIMEOUT)
+            timer = setTimeout(process, IDLE_TIMEOUT);
         if (queue.length == BATCHSIZE)
             await process();
     }, { noAck: false });
@@ -212,8 +212,8 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI,
         try {
             console.log("inserting batch into db");
             // upsert whole batch in parallel
-            await seq.transaction({ autocommit: false }, (transaction) => {
-                return Promise.all([
+            await seq.transaction({ autocommit: false }, async (transaction) => {
+                await Promise.all([
                     model.Match.bulkCreate(match_records, {
                         include: [ model.Roster, model.Asset ],
                         updateOnDuplicate: [],  // all
-- 
cgit v1.3.1