in granule_ingester/granule_ingester/writers/CassandraStore.py [0:0]
def _get_session(self) -> Session:
if self._username and self._password:
auth_provider = PlainTextAuthProvider(username=self._username, password=self._password)
else:
auth_provider = None
cluster = Cluster(contact_points=self._contact_points,
port=self._port,
# load_balancing_policy=
reconnection_policy=ConstantReconnectionPolicy(delay=5.0),
default_retry_policy=RetryPolicy(),
auth_provider=auth_provider)
session = cluster.connect()
session.set_keyspace(self._keyspace)
return session