@@ -724,7 +724,7 @@ def test_retrying_timeout_errors_doesnt_leak(self, respx_mock: MockRouter, clien
724
724
respx_mock .post ("/browsers" ).mock (side_effect = httpx .TimeoutException ("Test timeout error" ))
725
725
726
726
with pytest .raises (APITimeoutError ):
727
- client .browsers .with_streaming_response .create (invocation_id = "rr33xuugxj9h0bkf1rdt2bet" ).__enter__ ()
727
+ client .browsers .with_streaming_response .create ().__enter__ ()
728
728
729
729
assert _get_open_connections (self .client ) == 0
730
730
@@ -735,7 +735,7 @@ def test_retrying_status_errors_doesnt_leak(self, respx_mock: MockRouter, client
735
735
respx_mock .post ("/browsers" ).mock (return_value = httpx .Response (500 ))
736
736
737
737
with pytest .raises (APIStatusError ):
738
- client .browsers .with_streaming_response .create (invocation_id = "rr33xuugxj9h0bkf1rdt2bet" ).__enter__ ()
738
+ client .browsers .with_streaming_response .create ().__enter__ ()
739
739
assert _get_open_connections (self .client ) == 0
740
740
741
741
@pytest .mark .parametrize ("failures_before_success" , [0 , 2 , 4 ])
@@ -764,7 +764,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
764
764
765
765
respx_mock .post ("/browsers" ).mock (side_effect = retry_handler )
766
766
767
- response = client .browsers .with_raw_response .create (invocation_id = "rr33xuugxj9h0bkf1rdt2bet" )
767
+ response = client .browsers .with_raw_response .create ()
768
768
769
769
assert response .retries_taken == failures_before_success
770
770
assert int (response .http_request .headers .get ("x-stainless-retry-count" )) == failures_before_success
@@ -788,9 +788,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
788
788
789
789
respx_mock .post ("/browsers" ).mock (side_effect = retry_handler )
790
790
791
- response = client .browsers .with_raw_response .create (
792
- invocation_id = "rr33xuugxj9h0bkf1rdt2bet" , extra_headers = {"x-stainless-retry-count" : Omit ()}
793
- )
791
+ response = client .browsers .with_raw_response .create (extra_headers = {"x-stainless-retry-count" : Omit ()})
794
792
795
793
assert len (response .http_request .headers .get_list ("x-stainless-retry-count" )) == 0
796
794
@@ -813,9 +811,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
813
811
814
812
respx_mock .post ("/browsers" ).mock (side_effect = retry_handler )
815
813
816
- response = client .browsers .with_raw_response .create (
817
- invocation_id = "rr33xuugxj9h0bkf1rdt2bet" , extra_headers = {"x-stainless-retry-count" : "42" }
818
- )
814
+ response = client .browsers .with_raw_response .create (extra_headers = {"x-stainless-retry-count" : "42" })
819
815
820
816
assert response .http_request .headers .get ("x-stainless-retry-count" ) == "42"
821
817
@@ -1555,9 +1551,7 @@ async def test_retrying_timeout_errors_doesnt_leak(self, respx_mock: MockRouter,
1555
1551
respx_mock .post ("/browsers" ).mock (side_effect = httpx .TimeoutException ("Test timeout error" ))
1556
1552
1557
1553
with pytest .raises (APITimeoutError ):
1558
- await async_client .browsers .with_streaming_response .create (
1559
- invocation_id = "rr33xuugxj9h0bkf1rdt2bet"
1560
- ).__aenter__ ()
1554
+ await async_client .browsers .with_streaming_response .create ().__aenter__ ()
1561
1555
1562
1556
assert _get_open_connections (self .client ) == 0
1563
1557
@@ -1568,9 +1562,7 @@ async def test_retrying_status_errors_doesnt_leak(self, respx_mock: MockRouter,
1568
1562
respx_mock .post ("/browsers" ).mock (return_value = httpx .Response (500 ))
1569
1563
1570
1564
with pytest .raises (APIStatusError ):
1571
- await async_client .browsers .with_streaming_response .create (
1572
- invocation_id = "rr33xuugxj9h0bkf1rdt2bet"
1573
- ).__aenter__ ()
1565
+ await async_client .browsers .with_streaming_response .create ().__aenter__ ()
1574
1566
assert _get_open_connections (self .client ) == 0
1575
1567
1576
1568
@pytest .mark .parametrize ("failures_before_success" , [0 , 2 , 4 ])
@@ -1600,7 +1592,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
1600
1592
1601
1593
respx_mock .post ("/browsers" ).mock (side_effect = retry_handler )
1602
1594
1603
- response = await client .browsers .with_raw_response .create (invocation_id = "rr33xuugxj9h0bkf1rdt2bet" )
1595
+ response = await client .browsers .with_raw_response .create ()
1604
1596
1605
1597
assert response .retries_taken == failures_before_success
1606
1598
assert int (response .http_request .headers .get ("x-stainless-retry-count" )) == failures_before_success
@@ -1625,9 +1617,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
1625
1617
1626
1618
respx_mock .post ("/browsers" ).mock (side_effect = retry_handler )
1627
1619
1628
- response = await client .browsers .with_raw_response .create (
1629
- invocation_id = "rr33xuugxj9h0bkf1rdt2bet" , extra_headers = {"x-stainless-retry-count" : Omit ()}
1630
- )
1620
+ response = await client .browsers .with_raw_response .create (extra_headers = {"x-stainless-retry-count" : Omit ()})
1631
1621
1632
1622
assert len (response .http_request .headers .get_list ("x-stainless-retry-count" )) == 0
1633
1623
@@ -1651,9 +1641,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
1651
1641
1652
1642
respx_mock .post ("/browsers" ).mock (side_effect = retry_handler )
1653
1643
1654
- response = await client .browsers .with_raw_response .create (
1655
- invocation_id = "rr33xuugxj9h0bkf1rdt2bet" , extra_headers = {"x-stainless-retry-count" : "42" }
1656
- )
1644
+ response = await client .browsers .with_raw_response .create (extra_headers = {"x-stainless-retry-count" : "42" })
1657
1645
1658
1646
assert response .http_request .headers .get ("x-stainless-retry-count" ) == "42"
1659
1647
0 commit comments