@@ -128,11 +128,10 @@ async def _handle_recognize_media( # noqa: PLR0913
128
128
raise e
129
129
130
130
131
- async def _handle_play_text ( # noqa: PLR0913
131
+ async def _handle_play_text (
132
132
call : CallStateModel ,
133
133
client : CallAutomationClient ,
134
134
context : ContextEnum | None ,
135
- interrupt_queue : bool ,
136
135
style : MessageStyleEnum ,
137
136
text : str ,
138
137
) -> None :
@@ -146,7 +145,6 @@ async def _handle_play_text( # noqa: PLR0913
146
145
assert call .voice_id , "Voice ID is required for playing text"
147
146
async with _use_call_client (client , call .voice_id ) as call_client :
148
147
await call_client .play_media (
149
- interrupt_call_media_operation = interrupt_queue ,
150
148
operation_context = _context_builder ({context }),
151
149
play_source = _audio_from_text (
152
150
call = call ,
@@ -248,7 +246,6 @@ async def handle_recognize_text( # noqa: PLR0913
248
246
call = call ,
249
247
client = client ,
250
248
context = context ,
251
- interrupt_queue = chunck_interrupt_queue ,
252
249
style = style ,
253
250
text = chunk ,
254
251
)
@@ -259,7 +256,6 @@ async def handle_play_text( # noqa: PLR0913
259
256
client : CallAutomationClient ,
260
257
text : str ,
261
258
context : ContextEnum | None = None ,
262
- interrupt_queue : bool = False ,
263
259
store : bool = True ,
264
260
style : MessageStyleEnum = MessageStyleEnum .NONE ,
265
261
) -> None :
@@ -277,16 +273,11 @@ async def handle_play_text( # noqa: PLR0913
277
273
)
278
274
279
275
# Play each chunk
280
- for i , chunk in enumerate (chunks ):
281
- # For first chunk, interrupt media if needed
282
- chunck_interrupt_queue = interrupt_queue if i == 0 else False
283
-
284
- # Play text
276
+ for chunk in chunks :
285
277
await _handle_play_text (
286
278
call = call ,
287
279
client = client ,
288
280
context = context ,
289
- interrupt_queue = chunck_interrupt_queue ,
290
281
style = style ,
291
282
text = chunk ,
292
283
)
0 commit comments