(connection=None)
| 362 | |
| 363 | |
| 364 | def get_cluster(connection=None): |
| 365 | conn = get_connection(connection) |
| 366 | if not conn.cluster: |
| 367 | raise CQLEngineException("%s.cluster is not configured. Call one of the setup or default functions first." % __name__) |
| 368 | return conn.cluster |
| 369 | |
| 370 | |
| 371 | def register_udt(keyspace, type_name, klass, connection=None): |