From 6542cb321e044add7a8613a5ae39f44f06372cfd Mon Sep 17 00:00:00 2001 From: schneefux Date: Wed, 23 Aug 2017 19:28:20 +0200 Subject: send analyze_update to notification header --- worker.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/worker.py b/worker.py index 741fbc8..9ea7c26 100644 --- a/worker.py +++ b/worker.py @@ -142,6 +142,12 @@ def try_process(): for meth, prop, body in queue: channel.basic_ack(meth.delivery_tag) + + # notify web + if prop.headers.get("notify"): + channel.basic_publish("amq.topic", prop.headers.get("notify"), + "analyze_update") + if DOCRUNCHMATCH: # forward to cruncher_global channel.basic_publish(exchange="", @@ -243,10 +249,6 @@ def process(): participant.trueskill_delta = (float(player.trueskill_mu) - float(player.trueskill_sigma)) - (float(participant.trueskill_mu) - float(participant.trueskill_sigma)) db.commit() - # notify web - for api_id in ids: - channel.basic_publish("amq.topic", "match." + api_id, - "analyze_update") except: db.rollback() raise -- cgit v1.3.1