We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8031a77 commit 1d68ddfCopy full SHA for 1d68ddf
1 file changed
src/s2_sdk/_s2s/_append_session.py
@@ -202,6 +202,12 @@ async def _run_attempt(
202
):
203
frame_signal.reset()
204
205
+ if inflight_inputs:
206
+ raise S2ClientError(
207
+ f"Append session response stream closed with {len(inflight_inputs)} "
208
+ "unacknowledged batches"
209
+ )
210
+
211
212
async def _body_gen(
213
inflight_inputs: deque[_InflightInput],
0 commit comments