diff --git a/cassandra/concurrent.py b/cassandra/concurrent.py
index d6345ca452..ea0b00badb 100644
--- a/cassandra/concurrent.py
+++ b/cassandra/concurrent.py
@@ -204,7 +204,7 @@ def _results(self):
                     raise self._exception
         if self._exception and self._fail_fast:  # raise the exception even if there was no wait
             raise self._exception
-        return [r[1] for r in sorted(self._results_queue)]
+        return [r[1] for r in sorted(self._results_queue, key=lambda x: x[0])]