(self)
| 182 | logger.exception("Error in sending message via websocket") |
| 183 | |
| 184 | def _close_from_session(self): |
| 185 | conn = self._get_active_connection() |
| 186 | if conn and not conn.closed(): |
| 187 | self._send_msg_to_client() |
| 188 | conn.close() |
| 189 | elif self.reconnectable: # no active connection, and reconnect is enabled |
| 190 | _reconnect_state.session_will_messages[self.session_id] = self.session.get_task_commands() |
| 191 | self.session = None |
| 192 | |
| 193 | def send_client_data(self, data): |
| 194 | if isinstance(data, bytes): |
nothing calls this directly
no test coverage detected