fix(api): handle omission markers in queued WebSocket events (openai#3944)

## Summary

Fixes serialization errors when WebSocket events containing `omit` or
`not_given` are queued before the connection opens.

## Changes

- Support omission markers in dictionary events queued by synchronous
and asynchronous WebSocket connection managers.

Co-authored-by: marcuswood-oai <323319819+marcuswood-oai@users.noreply.github.com>

Author: marcuswood-oai

.castiron.stats.yml

@@ -1,8 +1,8 @@
 schema_version: 1
-generation_id: 85ad4660-a311-4438-9c8d-cdca0ec0f76a
+generation_id: ec3bb85c-c75f-4b0b-8713-a9377f2068d9
 openapi_spec_hash: 6ffdf0b6c2bafb456b14fda3f7231658
 openapi_transformed_spec_hash: d6d1e240c0615a9349169c2f2d04c388
 config_hash: 84cdcc959ee7140cc9a65e9b642c097b
-codegen_sha: 2284ccaf093c393669ee50253d011bb2a12c9f69
-codegen_hash: 70eb364ca64eb34fc66bed39b8f693f90c75dcd0c307489373cf360dcf3a2269
-public_codegen_sha: 75504785271618f32f21c7948959b7a390faf4f5
+codegen_sha: 878642b3dcf465c78f575b8e49ebc181b58fc5ce
+codegen_hash: 614193cc88f476d3dbfe7d149d8adf21489f235af4454fb1e93628fe43e1e351
+public_codegen_sha: 9a6784d449a729fc0e8d97a4947a8fa858a0041f

src/openai/resources/beta/responses/responses.py

@@ -4561,7 +4561,7 @@ def send(self, event: BetaResponsesClientEvent | BetaResponsesClientEventParam)
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, BetaResponsesClientEventParam))
         )
         self.__send_queue.enqueue(data)
 
@@ -5047,7 +5047,7 @@ def send(self, event: BetaResponsesClientEvent | BetaResponsesClientEventParam)
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, BetaResponsesClientEventParam))
         )
         self.__send_queue.enqueue(data)
 

src/openai/resources/live/forks.py

@@ -465,7 +465,7 @@ def send(self, event: ForkClientEvent | ForkClientEventParam) -> None:
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, ForkClientEventParam))
         )
         self.__send_queue.enqueue(data)
 
@@ -952,7 +952,7 @@ def send(self, event: ForkClientEvent | ForkClientEventParam) -> None:
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, ForkClientEventParam))
         )
         self.__send_queue.enqueue(data)
 

src/openai/resources/live/live.py

@@ -684,7 +684,7 @@ def send(self, event: ClientEvent | ClientEventParam) -> None:
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, ClientEventParam))
         )
         self.__send_queue.enqueue(data)
 
@@ -1166,7 +1166,7 @@ def send(self, event: ClientEvent | ClientEventParam) -> None:
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, ClientEventParam))
         )
         self.__send_queue.enqueue(data)
 

src/openai/resources/live/sideband.py

@@ -472,7 +472,7 @@ def send(self, event: ConnectClientEvent | ConnectClientEventParam) -> None:
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, ConnectClientEventParam))
         )
         self.__send_queue.enqueue(data)
 
@@ -964,7 +964,7 @@ def send(self, event: ConnectClientEvent | ConnectClientEventParam) -> None:
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, ConnectClientEventParam))
         )
         self.__send_queue.enqueue(data)
 

src/openai/resources/realtime/realtime.py

@@ -627,7 +627,7 @@ def send(self, event: RealtimeClientEvent | RealtimeClientEventParam) -> None:
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, RealtimeClientEventParam))
         )
         self.__send_queue.enqueue(data)
 
@@ -1138,7 +1138,7 @@ def send(self, event: RealtimeClientEvent | RealtimeClientEventParam) -> None:
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, RealtimeClientEventParam))
         )
         self.__send_queue.enqueue(data)
 

src/openai/resources/responses/responses.py

@@ -4408,7 +4408,7 @@ def send(self, event: ResponsesClientEvent | ResponsesClientEventParam) -> None:
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, ResponsesClientEventParam))
         )
         self.__send_queue.enqueue(data)
 
@@ -4906,7 +4906,7 @@ def send(self, event: ResponsesClientEvent | ResponsesClientEventParam) -> None:
         data = (
             event.to_json(use_api_names=True, exclude_defaults=True, exclude_unset=True)
             if isinstance(event, BaseModel)
-            else json.dumps(event)
+            else json.dumps(maybe_transform(event, ResponsesClientEventParam))
         )
         self.__send_queue.enqueue(data)