From 7ee4a6aab59b0e8be01b9b9ee542a3067f91e840 Mon Sep 17 00:00:00 2001
From: stainless-bot <dev@stainlessapi.com>
Date: Mon, 22 Apr 2024 18:04:00 +0000
Subject: [PATCH] feat(api): OpenAPI spec update via Stainless API

---
 tests/api_resources/queues/test_consumers.py | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/tests/api_resources/queues/test_consumers.py b/tests/api_resources/queues/test_consumers.py
index 20b325cd82f..4cd23d21213 100644
--- a/tests/api_resources/queues/test_consumers.py
+++ b/tests/api_resources/queues/test_consumers.py
@@ -37,6 +37,7 @@ def test_method_create(self, client: Cloudflare) -> None:
                     "max_retries": 3,
                     "max_wait_time_ms": 5000,
                 },
+                "type": "worker",
             },
         )
         assert_matches_type(Optional[ConsumerCreateResponse], consumer, path=["response"])
@@ -56,6 +57,7 @@ def test_raw_response_create(self, client: Cloudflare) -> None:
                     "max_retries": 3,
                     "max_wait_time_ms": 5000,
                 },
+                "type": "worker",
             },
         )
 
@@ -79,6 +81,7 @@ def test_streaming_response_create(self, client: Cloudflare) -> None:
                     "max_retries": 3,
                     "max_wait_time_ms": 5000,
                 },
+                "type": "worker",
             },
         ) as response:
             assert not response.is_closed
@@ -105,6 +108,7 @@ def test_path_params_create(self, client: Cloudflare) -> None:
                         "max_retries": 3,
                         "max_wait_time_ms": 5000,
                     },
+                    "type": "worker",
                 },
             )
 
@@ -121,6 +125,7 @@ def test_path_params_create(self, client: Cloudflare) -> None:
                         "max_retries": 3,
                         "max_wait_time_ms": 5000,
                     },
+                    "type": "worker",
                 },
             )
 
@@ -365,6 +370,7 @@ async def test_method_create(self, async_client: AsyncCloudflare) -> None:
                     "max_retries": 3,
                     "max_wait_time_ms": 5000,
                 },
+                "type": "worker",
             },
         )
         assert_matches_type(Optional[ConsumerCreateResponse], consumer, path=["response"])
@@ -384,6 +390,7 @@ async def test_raw_response_create(self, async_client: AsyncCloudflare) -> None:
                     "max_retries": 3,
                     "max_wait_time_ms": 5000,
                 },
+                "type": "worker",
             },
         )
 
@@ -407,6 +414,7 @@ async def test_streaming_response_create(self, async_client: AsyncCloudflare) ->
                     "max_retries": 3,
                     "max_wait_time_ms": 5000,
                 },
+                "type": "worker",
             },
         ) as response:
             assert not response.is_closed
@@ -433,6 +441,7 @@ async def test_path_params_create(self, async_client: AsyncCloudflare) -> None:
                         "max_retries": 3,
                         "max_wait_time_ms": 5000,
                     },
+                    "type": "worker",
                 },
             )
 
@@ -449,6 +458,7 @@ async def test_path_params_create(self, async_client: AsyncCloudflare) -> None:
                         "max_retries": 3,
                         "max_wait_time_ms": 5000,
                     },
+                    "type": "worker",
                 },
             )