(self, endpoint, kwargs_dict)
| 1639 | return partial(self.connection_class.factory, host.endpoint, self.connect_timeout, *args, **kwargs) |
| 1640 | |
| 1641 | def _make_connection_kwargs(self, endpoint, kwargs_dict): |
| 1642 | if self._auth_provider_callable: |
| 1643 | kwargs_dict.setdefault('authenticator', self._auth_provider_callable(endpoint.address)) |
| 1644 | |
| 1645 | kwargs_dict.setdefault('port', self.port) |
| 1646 | kwargs_dict.setdefault('compression', self.compression) |
| 1647 | kwargs_dict.setdefault('sockopts', self.sockopts) |
| 1648 | kwargs_dict.setdefault('ssl_options', self.ssl_options) |
| 1649 | kwargs_dict.setdefault('ssl_context', self.ssl_context) |
| 1650 | kwargs_dict.setdefault('cql_version', self.cql_version) |
| 1651 | kwargs_dict.setdefault('protocol_version', self.protocol_version) |
| 1652 | kwargs_dict.setdefault('user_type_map', self._user_types) |
| 1653 | kwargs_dict.setdefault('allow_beta_protocol_version', self.allow_beta_protocol_version) |
| 1654 | kwargs_dict.setdefault('no_compact', self.no_compact) |
| 1655 | |
| 1656 | return kwargs_dict |
| 1657 | |
| 1658 | def protocol_downgrade(self, host_endpoint, previous_version): |
| 1659 | if self._protocol_version_explicit: |
no outgoing calls
no test coverage detected