Skip to content

Commit 6284291

Browse files
committed
fix: let the error event bubble up the query error
1 parent 121c6dd commit 6284291

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

wherobots/db/connection.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,9 @@ def __listen(self):
132132
if query.state == ExecutionState.SUCCEEDED:
133133
self.__request_results(execution_id)
134134
elif query.state == ExecutionState.FAILED:
135-
query.handler(OperationalError("Query execution failed"))
135+
# Don't do anything here; the ERROR event is coming with more
136+
# details.
137+
pass
136138

137139
elif kind == EventKind.EXECUTION_RESULT:
138140
results = message.get("results")

0 commit comments

Comments
 (0)