We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5db7ae4 commit e6fc646Copy full SHA for e6fc646
roborock/devices/b01_channel.py
@@ -69,9 +69,11 @@ def find_response(response_message: RoborockMessage) -> None:
69
_LOGGER.debug("Sending MQTT message: %s", roborock_message)
70
try:
71
await mqtt_channel.publish(roborock_message)
72
- try:
73
- return await asyncio.wait_for(future, timeout=_TIMEOUT)
74
- except TimeoutError as ex:
75
- raise RoborockException(f"Command timed out after {_TIMEOUT}s") from ex
+ return await asyncio.wait_for(future, timeout=_TIMEOUT)
+ except TimeoutError as ex:
+ raise RoborockException(f"Command timed out after {_TIMEOUT}s") from ex
+ except Exception as ex:
76
+ _LOGGER.exception("Error sending decoded command: %s", ex)
77
+ raise
78
finally:
79
unsub()
0 commit comments