(self, plugin_name)
| 1150 | return pkt |
| 1151 | |
| 1152 | def _get_auth_plugin_handler(self, plugin_name): |
| 1153 | plugin_class = self._auth_plugin_map.get(plugin_name) |
| 1154 | if not plugin_class and isinstance(plugin_name, bytes): |
| 1155 | plugin_class = self._auth_plugin_map.get(plugin_name.decode("ascii")) |
| 1156 | if plugin_class: |
| 1157 | try: |
| 1158 | handler = plugin_class(self) |
| 1159 | except TypeError: |
| 1160 | raise err.OperationalError( |
| 1161 | CR.CR_AUTH_PLUGIN_CANNOT_LOAD, |
| 1162 | f"Authentication plugin '{plugin_name}'" |
| 1163 | f" not loaded: - {plugin_class!r} cannot be constructed with connection object", |
| 1164 | ) |
| 1165 | else: |
| 1166 | handler = None |
| 1167 | return handler |
| 1168 | |
| 1169 | # _mysql support |
| 1170 | def thread_id(self): |
no test coverage detected