diff --git a/src/openai/_utils/_sync.py b/src/openai/_utils/_sync.py
index 5d9e2c2ac9..8b3aaf2b5d 100644
--- a/src/openai/_utils/_sync.py
+++ b/src/openai/_utils/_sync.py
@@ -50,6 +50,7 @@ def blocking_func(arg1, arg2, kwarg1=None):
         # blocking code
         return result
 
+
     result = asyncify(blocking_function)(arg1, arg2, kwarg1=value1)
     ```
 
diff --git a/src/openai/resources/beta/realtime/realtime.py b/src/openai/resources/beta/realtime/realtime.py
index b39b410ecf..4a3089f48d 100644
--- a/src/openai/resources/beta/realtime/realtime.py
+++ b/src/openai/resources/beta/realtime/realtime.py
@@ -96,7 +96,7 @@ def connect(
         return RealtimeConnectionManager(
             client=self._client,
             extra_query=extra_query,
-            extra_headers=extra_headers,
+            extra_headers=extra_headers or self._client.default_headers,
             websocket_connection_options=websocket_connection_options,
             model=model,
         )
@@ -148,7 +148,7 @@ def connect(
         return AsyncRealtimeConnectionManager(
             client=self._client,
             extra_query=extra_query,
-            extra_headers=extra_headers,
+            extra_headers=extra_headers or self._client.default_headers,
             websocket_connection_options=websocket_connection_options,
             model=model,
         )
diff --git a/tests/lib/test_azure.py b/tests/lib/test_azure.py
index 626d7df311..a28aa8c2f6 100644
--- a/tests/lib/test_azure.py
+++ b/tests/lib/test_azure.py
@@ -153,7 +153,6 @@ def token_provider() -> str:
 
 
 class TestAzureLogging:
-
     @pytest.fixture(autouse=True)
     def logger_with_filter(self) -> logging.Logger:
         logger = logging.getLogger("openai")
@@ -165,9 +164,7 @@ def logger_with_filter(self) -> logging.Logger:
     def test_azure_api_key_redacted(self, respx_mock: MockRouter, caplog: pytest.LogCaptureFixture) -> None:
         respx_mock.post(
             "https://example-resource.azure.openai.com/openai/deployments/gpt-4/chat/completions?api-version=2024-06-01"
-        ).mock(
-            return_value=httpx.Response(200, json={"model": "gpt-4"})
-        )
+        ).mock(return_value=httpx.Response(200, json={"model": "gpt-4"}))
 
         client = AzureOpenAI(
             api_version="2024-06-01",
@@ -182,14 +179,11 @@ def test_azure_api_key_redacted(self, respx_mock: MockRouter, caplog: pytest.Log
             if is_dict(record.args) and record.args.get("headers") and is_dict(record.args["headers"]):
                 assert record.args["headers"]["api-key"] == "<redacted>"
 
-
     @pytest.mark.respx()
     def test_azure_bearer_token_redacted(self, respx_mock: MockRouter, caplog: pytest.LogCaptureFixture) -> None:
         respx_mock.post(
             "https://example-resource.azure.openai.com/openai/deployments/gpt-4/chat/completions?api-version=2024-06-01"
-        ).mock(
-            return_value=httpx.Response(200, json={"model": "gpt-4"})
-        )
+        ).mock(return_value=httpx.Response(200, json={"model": "gpt-4"}))
 
         client = AzureOpenAI(
             api_version="2024-06-01",
@@ -204,15 +198,12 @@ def test_azure_bearer_token_redacted(self, respx_mock: MockRouter, caplog: pytes
             if is_dict(record.args) and record.args.get("headers") and is_dict(record.args["headers"]):
                 assert record.args["headers"]["Authorization"] == "<redacted>"
 
-
     @pytest.mark.asyncio
     @pytest.mark.respx()
     async def test_azure_api_key_redacted_async(self, respx_mock: MockRouter, caplog: pytest.LogCaptureFixture) -> None:
         respx_mock.post(
             "https://example-resource.azure.openai.com/openai/deployments/gpt-4/chat/completions?api-version=2024-06-01"
-        ).mock(
-            return_value=httpx.Response(200, json={"model": "gpt-4"})
-        )
+        ).mock(return_value=httpx.Response(200, json={"model": "gpt-4"}))
 
         client = AsyncAzureOpenAI(
             api_version="2024-06-01",
@@ -227,15 +218,14 @@ async def test_azure_api_key_redacted_async(self, respx_mock: MockRouter, caplog
             if is_dict(record.args) and record.args.get("headers") and is_dict(record.args["headers"]):
                 assert record.args["headers"]["api-key"] == "<redacted>"
 
-
     @pytest.mark.asyncio
     @pytest.mark.respx()
-    async def test_azure_bearer_token_redacted_async(self, respx_mock: MockRouter, caplog: pytest.LogCaptureFixture) -> None:
+    async def test_azure_bearer_token_redacted_async(
+        self, respx_mock: MockRouter, caplog: pytest.LogCaptureFixture
+    ) -> None:
         respx_mock.post(
             "https://example-resource.azure.openai.com/openai/deployments/gpt-4/chat/completions?api-version=2024-06-01"
-        ).mock(
-            return_value=httpx.Response(200, json={"model": "gpt-4"})
-        )
+        ).mock(return_value=httpx.Response(200, json={"model": "gpt-4"}))
 
         client = AsyncAzureOpenAI(
             api_version="2024-06-01",