diff --git a/tests/websockets/test_graphql_transport_ws.py b/tests/websockets/test_graphql_transport_ws.py index e425d4675b..0d02cd9188 100644 --- a/tests/websockets/test_graphql_transport_ws.py +++ b/tests/websockets/test_graphql_transport_ws.py @@ -940,59 +940,3 @@ async def test_validation_subscription(ws: WebSocketClient): assert len(response["payload"]) == 1 assert response["payload"][0].get("path") == ["conditionalFail"] assert response["payload"][0]["message"] == "failed after sleep None" - - -async def test_long_validation_concurrent_query(ws: WebSocketClient): - """ - Test that the websocket is not blocked while validating a - single-result-operation - """ - await ws.send_json( - SubscribeMessage( - id="sub1", - payload=SubscribeMessagePayload( - query="query { conditionalFail(sleep:0.1) }" - ), - ).as_dict() - ) - await ws.send_json( - SubscribeMessage( - id="sub2", - payload=SubscribeMessagePayload( - query="query { conditionalFail(fail:false) }" - ), - ).as_dict() - ) - - # we expect the second query to arrive first, because the - # first query is stuck in validation - response = await ws.receive_json() - assert_next(response, "sub2", {"conditionalFail": "Hey"}) - - -async def test_long_validation_concurrent_subscription(ws: WebSocketClient): - """ - Test that the websocket is not blocked while validating a - subscription - """ - await ws.send_json( - SubscribeMessage( - id="sub1", - payload=SubscribeMessagePayload( - query="subscription { conditionalFail(sleep:0.1) }" - ), - ).as_dict() - ) - await ws.send_json( - SubscribeMessage( - id="sub2", - payload=SubscribeMessagePayload( - query="query { conditionalFail(fail:false) }" - ), - ).as_dict() - ) - - # we expect the second query to arrive first, because the - # first operation is stuck in validation - response = await ws.receive_json() - assert_next(response, "sub2", {"conditionalFail": "Hey"})