From 8346f68f2cad1b73594c249d9cb0d4be913caf80 Mon Sep 17 00:00:00 2001 From: Luke Sneeringer Date: Tue, 4 Nov 2014 11:16:53 -0600 Subject: [PATCH] Make pubsub.subscribe work. --- awx/main/queue.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/awx/main/queue.py b/awx/main/queue.py index 5708d3cbcd..21e84e3112 100644 --- a/awx/main/queue.py +++ b/awx/main/queue.py @@ -103,7 +103,7 @@ class PubSub(object): if message is None: time.sleep(max(wait, 0.001)) else: - yield json.loads(message) + yield json.loads(message['data']) def close(self): """Close the pubsub connection."""