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 556d81c commit 2afce5bCopy full SHA for 2afce5b
eventsourcingdb/client.py
@@ -187,6 +187,9 @@ async def run_eventql_query(self, query: str) -> AsyncGenerator[Any]:
187
async for raw_message in response.body:
188
message = parse_raw_message(raw_message)
189
190
+ if is_heartbeat(message):
191
+ continue
192
+
193
if is_stream_error(message):
194
error_message = message.get('payload', {}).get('error', 'Unknown error')
195
raise ServerError(f"{error_message}.")
@@ -329,4 +332,4 @@ async def read_event_types(self) -> AsyncGenerator[EventType]:
329
332
raise ServerError(
330
333
f'Failed to read event types, an unexpected '
331
334
f'stream item was received \'{message}\'.'
- )
335
+ )
0 commit comments