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