SDK regeneration

Author: fern-api[bot]

.fern/metadata.json

@@ -0,0 +1,13 @@
+{
+  "cliVersion": "3.5.0",
+  "generatorName": "fernapi/fern-python-sdk",
+  "generatorVersion": "4.45.0",
+  "generatorConfig": {
+    "client": {
+      "class_name": "Client",
+      "filename": "client.py",
+      "exported_class_name": "Pipedream",
+      "exported_filename": "pipedream.py"
+    }
+  }
+}

README.md

@@ -13,6 +13,7 @@ The Pipedream Python library provides convenient access to the Pipedream APIs fr
 - [Async Client](#async-client)
 - [Exception Handling](#exception-handling)
 - [Pagination](#pagination)
+- [Oauth Token Override](#oauth-token-override)
 - [Advanced](#advanced)
   - [Access Raw Response Data](#access-raw-response-data)
   - [Retries](#retries)
@@ -104,14 +105,48 @@ client = Pipedream(
     client_id="YOUR_CLIENT_ID",
     client_secret="YOUR_CLIENT_SECRET",
 )
-response = client.apps.list()
+response = client.apps.list(
+    after="after",
+    before="before",
+    limit=1,
+    q="q",
+    sort_key="name",
+    sort_direction="asc",
+)
 for item in response:
     yield item
 # alternatively, you can paginate page-by-page
 for page in response.iter_pages():
     yield page
 ```
 
+```python
+# You can also iterate through pages and access the typed response per page
+pager = client.apps.list(...)
+for page in pager.iter_pages():
+    print(page.response)  # access the typed response for each page
+    for item in page:
+        print(item)
+```
+
+## Oauth Token Override
+
+This SDK supports two authentication methods: OAuth client credentials flow (automatic token management) or direct bearer token authentication. You can choose between these options when initializing the client:
+
+```python
+from pipedream import Pipedream
+
+# Option 1: Direct bearer token (bypass OAuth flow)
+client = Pipedream(..., token="my-pre-generated-bearer-token")
+
+from pipedream import Pipedream
+
+# Option 2: OAuth client credentials flow (automatic token management)
+client = Pipedream(
+    ..., client_id="your-client-id", client_secret="your-client-secret"
+)
+```
+
 ## Advanced
 
 ### Access Raw Response Data
@@ -129,11 +164,11 @@ response = client.actions.with_raw_response.run(...)
 print(response.headers)  # access the response headers
 print(response.data)  # access the underlying object
 pager = client.apps.list(...)
-print(pager.response.headers)  # access the response headers for the first page
+print(pager.response)  # access the typed response for the first page
 for item in pager:
     print(item)  # access the underlying object(s)
 for page in pager.iter_pages():
-    print(page.response.headers)  # access the response headers for each page
+    print(page.response)  # access the typed response for each page
     for item in page:
         print(item)  # access the underlying object(s)
 ```

poetry.lock

@@ -1,9 +1,10 @@
 [project]
 name = "pipedream"
+dynamic = ["version"]
 
 [tool.poetry]
 name = "pipedream"
-version = "1.0.12"
+version = "1.0.13"
 description = ""
 readme = "README.md"
 authors = []
@@ -30,7 +31,7 @@ packages = [
     { include = "pipedream", from = "src"}
 ]
 
-[project.urls]
+[tool.poetry.urls]
 Repository = 'https://github.com/PipedreamHQ/pipedream-sdk-python'
 
 [tool.poetry.dependencies]
@@ -44,6 +45,7 @@ typing_extensions = ">= 4.0.0"
 mypy = "==1.13.0"
 pytest = "^7.4.0"
 pytest-asyncio = "^0.23.5"
+pytest-xdist = "^3.6.1"
 python-dateutil = "^2.9.0"
 types-python-dateutil = "^2.9.0.20240316"
 ruff = "==0.11.5"

pyproject.toml

@@ -6,6 +6,7 @@
 from ..core.pagination import AsyncPager, SyncPager
 from ..core.request_options import RequestOptions
 from ..types.account import Account
+from ..types.list_accounts_response import ListAccountsResponse
 from .raw_client import AsyncRawAccountsClient, RawAccountsClient
 
 # this is used as the default value for optional parameters
@@ -38,7 +39,7 @@ def list(
         app: typing.Optional[str] = None,
         include_credentials: typing.Optional[bool] = None,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> SyncPager[Account]:
+    ) -> SyncPager[Account, ListAccountsResponse]:
         """
         Retrieve all connected accounts for the project with optional filtering
 
@@ -69,7 +70,7 @@ def list(
 
         Returns
         -------
-        SyncPager[Account]
+        SyncPager[Account, ListAccountsResponse]
             accounts listed
 
         Examples
@@ -82,7 +83,15 @@ def list(
             client_id="YOUR_CLIENT_ID",
             client_secret="YOUR_CLIENT_SECRET",
         )
-        response = client.accounts.list()
+        response = client.accounts.list(
+            external_user_id="external_user_id",
+            oauth_app_id="oauth_app_id",
+            after="after",
+            before="before",
+            limit=1,
+            app="app",
+            include_credentials=True,
+        )
         for item in response:
             yield item
         # alternatively, you can paginate page-by-page
@@ -152,6 +161,8 @@ def create(
             client_secret="YOUR_CLIENT_SECRET",
         )
         client.accounts.create(
+            external_user_id="external_user_id",
+            oauth_app_id="oauth_app_id",
             app_slug="app_slug",
             cfmap_json="cfmap_json",
             connect_token="connect_token",
@@ -205,6 +216,7 @@ def retrieve(
         )
         client.accounts.retrieve(
             account_id="account_id",
+            include_credentials=True,
         )
         """
         _response = self._raw_client.retrieve(
@@ -303,7 +315,7 @@ async def list(
         app: typing.Optional[str] = None,
         include_credentials: typing.Optional[bool] = None,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> AsyncPager[Account]:
+    ) -> AsyncPager[Account, ListAccountsResponse]:
         """
         Retrieve all connected accounts for the project with optional filtering
 
@@ -334,7 +346,7 @@ async def list(
 
         Returns
         -------
-        AsyncPager[Account]
+        AsyncPager[Account, ListAccountsResponse]
             accounts listed
 
         Examples
@@ -352,7 +364,15 @@ async def list(
 
 
         async def main() -> None:
-            response = await client.accounts.list()
+            response = await client.accounts.list(
+                external_user_id="external_user_id",
+                oauth_app_id="oauth_app_id",
+                after="after",
+                before="before",
+                limit=1,
+                app="app",
+                include_credentials=True,
+            )
             async for item in response:
                 yield item
 
@@ -431,6 +451,8 @@ async def create(
 
         async def main() -> None:
             await client.accounts.create(
+                external_user_id="external_user_id",
+                oauth_app_id="oauth_app_id",
                 app_slug="app_slug",
                 cfmap_json="cfmap_json",
                 connect_token="connect_token",
@@ -492,6 +514,7 @@ async def retrieve(
         async def main() -> None:
             await client.accounts.retrieve(
                 account_id="account_id",
+                include_credentials=True,
             )