Skip to content

Commit 1034fd3

Browse files
brianjlailmossman
andauthored
Update airbyte_cdk/connector_builder/test_reader/message_grouper.py
Co-authored-by: Lake Mossman <[email protected]>
1 parent c7562b8 commit 1034fd3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

airbyte_cdk/connector_builder/test_reader/message_grouper.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -97,11 +97,11 @@ def get_message_groups(
9797

9898
while message := next(messages, None):
9999
# Even though we do not emit records beyond the limit in the message group response, we still
100-
# need to process messages off the queue in order to avoid a deadlock occurs if the amount
100+
# need to process messages off the queue in order to avoid a deadlock that occurs if the amount
101101
# of extracted records exceeds the size of the queue (which has a default of 10,000)
102102
#
103103
# A few other options considered was killing the thread pool, but that doesn't kill in-progress
104-
# in-progress threads. We also considered adding another event to the main queue, but this is
104+
# threads. We also considered adding another event to the main queue, but this is
105105
# the simplest solution for the time being.
106106
if records_count >= limit:
107107
continue

0 commit comments

Comments
 (0)