From 812baa8b75243175294186163b13ce25b3f852f8 Mon Sep 17 00:00:00 2001 From: schneefux Date: Tue, 25 Jul 2017 14:29:07 +0200 Subject: do not forward to cruncher, data depends on analyzer --- worker.js | 7 ------- 1 file changed, 7 deletions(-) diff --git a/worker.js b/worker.js index 16f7708..37cc25a 100644 --- a/worker.js +++ b/worker.js @@ -26,8 +26,6 @@ const RABBITMQ_URI = process.env.RABBITMQ_URI, MAXCONNS = parseInt(process.env.MAXCONNS) || 10, // how many concurrent actions DOANALYZEMATCH = process.env.DOANALYZEMATCH == "true", ANALYZE_QUEUE = process.env.ANALYZE_QUEUE || "analyze", - DOCRUNCHMATCH = process.env.DOCRUNCHMATCH == "true", - CRUNCH_PLAYER_QUEUE = process.env.CRUNCH_PLAYER_QUEUE || "crunch_player", LOAD_TIMEOUT = parseFloat(process.env.LOAD_TIMEOUT) || 5000, // ms IDLE_TIMEOUT = parseFloat(process.env.IDLE_TIMEOUT) || 700; // ms @@ -277,11 +275,6 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { await Promise.each(match_objects, async (m) => await ch.sendToQueue(ANALYZE_QUEUE, new Buffer(m.id), { persistent: true })); - if (DOCRUNCHMATCH) { - await Promise.each(match_objects, async (m) => - await ch.sendToQueue(CRUNCH_PLAYER_QUEUE, new Buffer(m.id), - { persistent: true })); - } } catch (err) { if (err instanceof Seq.TimeoutError) { // deadlocks / timeout -- cgit v1.3.1