diff --git a/src/config/common/cfgm_common/datastore/drivers/cassandra_cql.py b/src/config/common/cfgm_common/datastore/drivers/cassandra_cql.py index 8a8a61c2a4f..cb69d4a8c9c 100644 --- a/src/config/common/cfgm_common/datastore/drivers/cassandra_cql.py +++ b/src/config/common/cfgm_common/datastore/drivers/cassandra_cql.py @@ -317,13 +317,16 @@ def _Init_Cluster(self): password=self.options.credential.get('password')) # SSL related options - ssl_options, ssl_context = None, None + ssl_options = None if self.options.ssl_enabled: - ssl_context = ssl.SSLContext(SSL_VERSION) - ssl_context.load_verify_locations(self.options.ca_certs) - ssl_context.verify_mode = ssl.CERT_REQUIRED - ssl_context.check_hostname = False - ssl_options = {} + # TODO(sahid): Future versions (>= 3.17) will support + # ssl_context. + ssl_options = { + "ssl_version": SSL_VERSION, + "ca_certs": self.options.ca_certs, + "check_hostname": False, + "cert_reqs": ssl.CERT_REQUIRED, + } # Profiles related features ExecutionProfile = connector.cluster.ExecutionProfile @@ -349,7 +352,6 @@ def _Init_Cluster(self): self._cluster = connector.cluster.Cluster( endpoints, ssl_options=ssl_options, - ssl_context=ssl_context, auth_provider=auth_provider, execution_profiles=profiles, cql_version=self.CqlVersion)