Avoid changes in core module

Author: jverce

src/pipedream/core/client_wrapper.py

@@ -120,8 +120,3 @@ async def async_get_headers(self) -> typing.Dict[str, str]:
             token = await self._async_token()
             headers["Authorization"] = f"Bearer {token}"
         return headers
-
-    async def _async_get_token(self) -> typing.Optional[str]:
-        if self._async_token is not None:
-            return await self._async_token()
-        return self._get_token()

src/pipedream/pipedream.py

@@ -112,20 +112,25 @@ def raw_access_token(self) -> Optional[str]:
         """
         Returns an access token that can be used to authenticate API requests.
 
-        Note: When using OAuth authentication (client_id/client_secret), this property
-        may perform blocking network operations. For async applications, prefer using
-        the async method `get_raw_access_token()` instead.
+        Note: When using OAuth authentication (`client_id`/`client_secret`),
+        this property may perform blocking network operations. For async
+        applications, prefer using the async property `async_raw_access_token`
+        instead.
         """
         return self._client_wrapper._get_token()
 
-    async def get_raw_access_token(self) -> Optional[str]:
+    @property
+    async def async_raw_access_token(self) -> Optional[str]:
         """
-        Asynchronously returns an access token that can be used to authenticate API requests.
+        Asynchronously returns an access token that can be used to authenticate
+        API requests.
 
-        This method is non-blocking and safe to use in async contexts such as FastAPI,
-        Django ASGI, or any other asyncio-based application.
+        This method is non-blocking and safe to use in async contexts such as
+        FastAPI, Django ASGI, or any other asyncio-based application.
         """
-        return await self._client_wrapper._async_get_token()
+        if self._client_wrapper._async_token is not None:
+            return await self._client_wrapper._async_token()
+        return self.raw_access_token
 
 
 def _get_base_url(environment: PipedreamEnvironment) -> str:

tests/custom/test_client.py

@@ -23,14 +23,14 @@ def test_async_pipedream_raw_access_token() -> None:
     assert client.raw_access_token == "test-token"
 
 
-async def test_async_pipedream_get_raw_access_token() -> None:
-    """Test AsyncPipedream async method get_raw_access_token() with access_token."""
+async def test_async_pipedream_async_raw_access_token() -> None:
+    """Test AsyncPipedream async method async_raw_access_token() with access_token."""
     client = AsyncPipedream(access_token="test-token", project_id="test-project")
-    token = await client.get_raw_access_token()
+    token = await client.async_raw_access_token
     assert token == "test-token"
 
 
-async def test_async_pipedream_get_raw_access_token_with_oauth() -> None:
+async def test_async_pipedream_async_raw_access_token_with_oauth() -> None:
     """Test AsyncPipedream async method with OAuth flow."""
     client = AsyncPipedream(
         client_id="test-client-id",
@@ -45,5 +45,5 @@ async def test_async_pipedream_get_raw_access_token_with_oauth() -> None:
     client._client_wrapper._async_token = AsyncMock(return_value="mocked-oauth-token")
 
     # Test the async method
-    token = await client.get_raw_access_token()
+    token = await client.async_raw_access_token
     assert token == "mocked-oauth-token"