(control_conn, response_future, connection, **kwargs)
| 4312 | |
| 4313 | |
| 4314 | def refresh_schema_and_set_result(control_conn, response_future, connection, **kwargs): |
| 4315 | try: |
| 4316 | log.debug("Refreshing schema in response to schema change. " |
| 4317 | "%s", kwargs) |
| 4318 | response_future.is_schema_agreed = control_conn._refresh_schema(connection, **kwargs) |
| 4319 | except Exception: |
| 4320 | log.exception("Exception refreshing schema in response to schema change:") |
| 4321 | response_future.session.submit(control_conn.refresh_schema, **kwargs) |
| 4322 | finally: |
| 4323 | response_future._set_final_result(None) |
| 4324 | |
| 4325 | |
| 4326 | class ResponseFuture(object): |
nothing calls this directly
no test coverage detected