

def connect(self):
    if ((not self.connected) or (self.connection is None)):
        settings = self.settings_dict
        self.connection = CassandraConnection(**settings)
        connection_created.send(sender=self.__class__, connection=self)
        self.connected = True

dataset/ETHPy150Open r4fek/django-cassandra-engine/django_cassandra_engine/base/__init__.py DatabaseWrapper.connect/original