add forward to sewer optionrelease/2.18.0

1 files changed, 8 insertions, 0 deletions

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")