From bba2edb35ea17b97922bb1e2f1f19124cd30477f Mon Sep 17 00:00:00 2001 From: schneefux Date: Tue, 3 Oct 2017 11:50:49 +0200 Subject: add forward to sewer option --- worker.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/worker.py b/worker.py index 9ea7c26..fb9b2b1 100644 --- a/worker.py +++ b/worker.py @@ -25,6 +25,8 @@ DOCRUNCHMATCH = os.environ.get("DOCRUNCHMATCH") == "true" CRUNCH_QUEUE = os.environ.get("CRUNCH_QUEUE") or "crunch_global" DOTELESUCKMATCH = os.environ.get("DOTELESUCKMATCH") == "true" TELESUCK_QUEUE = os.environ.get("TELESUCK_QUEUE") or "telesuck" +DOSEWMATCH = os.environ.get("DOSEWMATCH") == "true" +SEW_QUEUE = os.environ.get("SEW_QUEUE") or "sew" UNKNOWN_PLAYER_SIGMA = int(os.environ.get("UNKNOWN_PLAYER_SIGMA") or 500) # mapping from Tier (-1 - 30) to average skill tier points @@ -154,6 +156,12 @@ def try_process(): routing_key=CRUNCH_QUEUE, body=body, properties=prop) + if DOSEWMATCH: + # forward to sewer + channel.basic_publish(exchange="", + routing_key=SEW_QUEUE, + body=body, + properties=prop) if DOTELESUCKMATCH: # forward asset url to telesucker id = str(body, "utf-8") -- cgit v1.3.1