feat: handle error events

Author: mpetazzoni

wherobots/db/connection.py

@@ -153,6 +153,10 @@ def __listen(self):
                                 f"Unsupported results format {result_format}"
                             )
                         )
+            case EventKind.ERROR:
+                query.state = ExecutionState.FAILED
+                error = message.get("message")
+                query.handler(OperationalError(error))
             case _:
                 logging.warning("Received unknown %s event!", kind)
 

wherobots/db/constants.py

@@ -46,6 +46,7 @@ class RequestKind(StrEnum):
 class EventKind(StrEnum):
     STATE_UPDATED = auto()
     EXECUTION_RESULT = auto()
+    ERROR = auto()
 
 
 class ResultsFormat(StrEnum):