Synchronously refresh all schema metadata. By default, the timeout for this operation is governed by :attr:`~.Cluster.max_schema_agreement_wait` and :attr:`~.Cluster.control_connection_timeout`. Passing max_schema_agreement_wait here overrides :attr:`~.Cluster.max_
(self, max_schema_agreement_wait=None)
| 2150 | return self.metadata.get_host(endpoint) if endpoint else None |
| 2151 | |
| 2152 | def refresh_schema_metadata(self, max_schema_agreement_wait=None): |
| 2153 | """ |
| 2154 | Synchronously refresh all schema metadata. |
| 2155 | |
| 2156 | By default, the timeout for this operation is governed by :attr:`~.Cluster.max_schema_agreement_wait` |
| 2157 | and :attr:`~.Cluster.control_connection_timeout`. |
| 2158 | |
| 2159 | Passing max_schema_agreement_wait here overrides :attr:`~.Cluster.max_schema_agreement_wait`. |
| 2160 | |
| 2161 | Setting max_schema_agreement_wait <= 0 will bypass schema agreement and refresh schema immediately. |
| 2162 | |
| 2163 | An Exception is raised if schema refresh fails for any reason. |
| 2164 | """ |
| 2165 | if not self.control_connection.refresh_schema(schema_agreement_wait=max_schema_agreement_wait, force=True): |
| 2166 | raise DriverException("Schema metadata was not refreshed. See log for details.") |
| 2167 | |
| 2168 | def refresh_keyspace_metadata(self, keyspace, max_schema_agreement_wait=None): |
| 2169 | """ |