Method _make_connection_factory

cassandra/cluster.py:1637–1639

(self, host, *args, **kwargs)

        return self.connection_class.factory(endpoint, self.connect_timeout, *args, **kwargs)

    def _make_connection_factory(self, host, *args, **kwargs):
        kwargs = self._make_connection_kwargs(host.endpoint, kwargs)
        return partial(self.connection_class.factory, host.endpoint, self.connect_timeout, *args, **kwargs)

    def _make_connection_kwargs(self, endpoint, kwargs_dict):
        if self._auth_provider_callable: