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