AMQP Result backend: Fixed ugly bug with result.get() if CELERY_TRACK_STARTED=True

celery/backends/amqp.py

@@ -169,8 +169,9 @@ class AMQPBackend(BaseDictBackend):
     def consume(self, task_id, timeout=None):
         results = []
 
-        def callback(message_data, message):
-            results.append(message_data)
+        def callback(meta, message):
+            if meta["status"] in states.READY_STATES:
+                results.append(meta)
 
         wait = self.connection.drain_events
         consumer = self._create_consumer(task_id, self.connection)