(self)
| 122 | self.setup_session() |
| 123 | |
| 124 | def setup_session(self): |
| 125 | if self.cluster._config_mode == _ConfigMode.PROFILES: |
| 126 | self.cluster.profile_manager.default.row_factory = dict_factory |
| 127 | if self.consistency is not None: |
| 128 | self.cluster.profile_manager.default.consistency_level = self.consistency |
| 129 | else: |
| 130 | self.session.row_factory = dict_factory |
| 131 | if self.consistency is not None: |
| 132 | self.session.default_consistency_level = self.consistency |
| 133 | enc = self.session.encoder |
| 134 | enc.mapping[tuple] = enc.cql_encode_tuple |
| 135 | _register_known_types(self.session.cluster) |
| 136 | |
| 137 | def handle_lazy_connect(self): |
| 138 |
no test coverage detected