(self, message)
| 139 | self.sockets = set() |
| 140 | |
| 141 | def check_error(self, message): |
| 142 | if isinstance(message, dict) and len(message) == 1 and "_e" in message: |
| 143 | self.engine_debug(f"{self.name}: got error message: {message}") |
| 144 | error, trace = message["_e"] |
| 145 | error = self.ERROR_CLASS(error) |
| 146 | error.engine_traceback = trace |
| 147 | self.engine_debug(f"{self.name}: raising {error.__class__.__name__}") |
| 148 | raise error |
| 149 | return False |
| 150 | |
| 151 | async def run_and_return(self, command, *args, **kwargs): |
| 152 | fn_str = f"{command}({args}, {kwargs})" |
no test coverage detected