Skip to content

Commit 1a8f867

Browse files
fix: Ignore heartbeat messages during EventQL query (#109)
1 parent 556d81c commit 1a8f867

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

eventsourcingdb/client.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,9 @@ async def run_eventql_query(self, query: str) -> AsyncGenerator[Any]:
187187
async for raw_message in response.body:
188188
message = parse_raw_message(raw_message)
189189

190+
if is_heartbeat(message):
191+
continue
192+
190193
if is_stream_error(message):
191194
error_message = message.get('payload', {}).get('error', 'Unknown error')
192195
raise ServerError(f"{error_message}.")
@@ -329,4 +332,4 @@ async def read_event_types(self) -> AsyncGenerator[EventType]:
329332
raise ServerError(
330333
f'Failed to read event types, an unexpected '
331334
f'stream item was received \'{message}\'.'
332-
)
335+
)

0 commit comments

Comments
 (0)