openstack/deb-python-cassandra-driver
Code Issues Proposed changes

add comment

Browse Source
This commit is contained in:
Alan Boudreault
2017-04-24 12:38:37 -04:00
parent 6fb7c6f205
commit 5b143c9c12
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
cassandra/query.py
View File

@@ -925,6 +925,7 @@ class QueryTrace(object):
session_results = self._execute(
SimpleStatement(self._SELECT_SESSIONS_FORMAT, consistency_level=query_cl), (self.trace_id,), time_spent, max_wait)
# PYTHON-730: There is race condition that the duration mutation is written before started_at the for fast queries
is_complete = session_results and session_results[0].duration is not None and session_results[0].started_at is not None
if not session_results or (wait_for_complete and not is_complete):
time.sleep(self._BASE_RETRY_SLEEP * (2 ** attempt))