summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--worker.js2
1 files changed, 0 insertions, 2 deletions
diff --git a/worker.js b/worker.js
index 4f59088..db53864 100644
--- a/worker.js
+++ b/worker.js
@@ -389,7 +389,6 @@ function flatten(obj) {
// now access db
try {
// upsert whole batch in parallel
- await seq.query("SET unique_checks=0");
logger.info("inserting batch into db");
await seq.transaction({ autocommit: false }, async (transaction) => {
await Promise.all([
@@ -447,7 +446,6 @@ function flatten(obj) {
)
])
});
- await seq.query("SET unique_checks=1");
logger.info("acking batch", { size: msgs.size });
for (let msg of msgs)