Skip to content

Commit 4e58269

Browse files
Ensure our Semaphore is kept in line with the buffer length
1 parent 62e7c83 commit 4e58269

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/replit_river/common_session.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -166,15 +166,18 @@ async def buffered_message_sender(
166166
type(e),
167167
exc_info=e,
168168
)
169+
message_enqueued.release()
169170
break
170171
except FailedSendingMessageException:
171172
logger.error(
172173
"Failed sending message, waiting for retry from buffer",
173174
exc_info=True,
174175
)
176+
message_enqueued.release()
175177
break
176178
except Exception:
177179
logger.exception("Error attempting to send buffered messages")
180+
message_enqueued.release()
178181
break
179182

180183

0 commit comments

Comments
 (0)