(self, message: str)
| 158 | return self._result |
| 159 | |
| 160 | def log(self, message: str) -> None: |
| 161 | self._logs.append(message) |
| 162 | try: |
| 163 | self._channel._connection.wrap_api_call_sync( |
| 164 | lambda: self._channel.send_no_reply( |
| 165 | "__waitInfo__", |
| 166 | None, |
| 167 | { |
| 168 | "waitId": self._wait_id, |
| 169 | "phase": "log", |
| 170 | "message": message, |
| 171 | }, |
| 172 | ), |
| 173 | True, |
| 174 | ) |
| 175 | except Exception: |
| 176 | pass |
| 177 | |
| 178 | |
| 179 | def throw_on_timeout(timeout: float, exception: Exception) -> asyncio.Task: |
no test coverage detected