diff --git a/api/routes/telephony.py b/api/routes/telephony.py index 29b62359..827b0cbf 100644 --- a/api/routes/telephony.py +++ b/api/routes/telephony.py @@ -686,9 +686,6 @@ async def _handle_telephony_websocket( except RuntimeError: # WebSocket already closed, ignore pass - finally: - await call_concurrency.unregister_active_call(workflow_run_id) - @router.post("/inbound/run") async def handle_inbound_run(request: Request): diff --git a/api/tests/test_telephony_routes.py b/api/tests/test_telephony_routes.py index 24d8a7d8..f92c63d3 100644 --- a/api/tests/test_telephony_routes.py +++ b/api/tests/test_telephony_routes.py @@ -393,4 +393,4 @@ async def test_smallwebrtc_run_reaching_telephony_websocket_closes_without_runni ) assert mock_db.update_workflow_run.await_count == 0 assert provider_lookup.await_count == 0 - mock_concurrency.unregister_active_call.assert_awaited_once_with(501) + mock_concurrency.unregister_active_call.assert_not_awaited()