Skip to content

Instantly share code, notes, and snippets.

@beltran
Created July 17, 2017 17:15
Show Gist options
  • Save beltran/62b4fa1ae61b7db70a2e2a45fbd3a2fe to your computer and use it in GitHub Desktop.
Save beltran/62b4fa1ae61b7db70a2e2a45fbd3a2fe to your computer and use it in GitHub Desktop.
from cassandra.cluster import Cluster
cluster = Cluster()
def context():
session = cluster.connect(wait_for_all_pools=True)
context()
for connections in [o.get_connections() for o in cluster.get_connection_holders()]:
for connection in connections:
if not connection.is_control_connection:
assert connection.is_closed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment