File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -194,7 +194,8 @@ async def run_eventql_query(self, query: str) -> AsyncGenerator[Any]:
194194 message = parse_raw_message (raw_message )
195195
196196 if is_stream_error (message ):
197- raise ServerError (f'{ message ['payload' ]['error' ]} .' )
197+ error_message = message .get ('payload' , {}).get ('error' , 'Unknown error' )
198+ raise ServerError (f"{ error_message } ." )
198199 # pylint: disable=R2004
199200 if message .get ('type' ) == 'row' :
200201 payload = message ['payload' ]
@@ -203,7 +204,7 @@ async def run_eventql_query(self, query: str) -> AsyncGenerator[Any]:
203204 continue
204205
205206 raise ServerError (
206- f 'Failed to execute EventQL query, an unexpected stream item was received: '
207+ 'Failed to execute EventQL query, an unexpected stream item was received: '
207208 f'{ message } .'
208209 )
209210
You can’t perform that action at this time.
0 commit comments