Ensure shutdown_on_error is set before defuncting the connection

aboudreault · aboudreault · commit e57450c3ffe3 · 2017-06-16T07:29:11.000-04:00
diff --git a/cassandra/connection.py b/cassandra/connection.py
@@ -1012,10 +1012,10 @@ def run(self):
 
 for connection, owner, exc in failed_connections:
 self._raise_if_stopped()
- connection.defunct(exc)
 if not connection.is_control_connection:
 # Only HostConnection supports shutdown_on_error
 owner.shutdown_on_error = True
+ connection.defunct(exc)
 owner.return_connection(connection)
 except self.ShutdownException:
 pass

-Original file line number
+Diff line change
 forconnection, owner, excinfailed_connections:
 self._raise_if_stopped()
 -connection.defunct(exc)
 ifnotconnection.is_control_connection:
 # Only HostConnection supports shutdown_on_error
 owner.shutdown_on_error=True
 +connection.defunct(exc)
 owner.return_connection(connection)
 exceptself.ShutdownException:
 pass