SDK regeneration

.fern/metadata.json

@@ -10,9 +10,9 @@
       "exported_filename": "pipedream.py"
     }
   },
-  "originGitCommit": "729a65c6931057ef726cbf54bc9603b5d93c752a",
+  "originGitCommit": "4ec89179f0cd7c09cc536f40a9c42a089d9cd425",
   "originGitCommitIsDirty": false,
   "invokedBy": "ci",
   "ciProvider": "github",
-  "sdkVersion": "2.1.19"
-}
+  "sdkVersion": "2.1.20"
+}

pyproject.toml

@@ -4,7 +4,7 @@ dynamic = ["version"]
 
 [tool.poetry]
 name = "pipedream"
-version = "2.1.19"
+version = "2.1.20"
 description = ""
 readme = "README.md"
 authors = []

src/pipedream/accounts/client.py

@@ -118,6 +118,7 @@ def create(
         oauth_app_id: typing.Optional[str] = None,
         name: typing.Optional[str] = OMIT,
         account_id: typing.Optional[str] = OMIT,
+        app_override_id: typing.Optional[str] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> Account:
         """
@@ -145,6 +146,9 @@ def create(
         account_id : typing.Optional[str]
             An existing account ID to reconnect. When provided, the account's credentials are updated instead of creating a new account. Must belong to the same external user and project environment as the connect token, and match the app identified by app_slug.
 
+        app_override_id : typing.Optional[str]
+            An app override ID. The account is linked to the override and the override's pre-defined custom field values are merged over cfmap_json; with account_id, the account is re-linked to this override. Must belong to the app identified by app_slug, and must not select an OAuth client — overrides that do can only connect through the OAuth flow.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -178,6 +182,7 @@ def create(
             oauth_app_id=oauth_app_id,
             name=name,
             account_id=account_id,
+            app_override_id=app_override_id,
             request_options=request_options,
         )
         return _response.data
@@ -450,6 +455,7 @@ async def create(
         oauth_app_id: typing.Optional[str] = None,
         name: typing.Optional[str] = OMIT,
         account_id: typing.Optional[str] = OMIT,
+        app_override_id: typing.Optional[str] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> Account:
         """
@@ -477,6 +483,9 @@ async def create(
         account_id : typing.Optional[str]
             An existing account ID to reconnect. When provided, the account's credentials are updated instead of creating a new account. Must belong to the same external user and project environment as the connect token, and match the app identified by app_slug.
 
+        app_override_id : typing.Optional[str]
+            An app override ID. The account is linked to the override and the override's pre-defined custom field values are merged over cfmap_json; with account_id, the account is re-linked to this override. Must belong to the app identified by app_slug, and must not select an OAuth client — overrides that do can only connect through the OAuth flow.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -518,6 +527,7 @@ async def main() -> None:
             oauth_app_id=oauth_app_id,
             name=name,
             account_id=account_id,
+            app_override_id=app_override_id,
             request_options=request_options,
         )
         return _response.data

src/pipedream/accounts/raw_client.py

@@ -139,6 +139,7 @@ def create(
         oauth_app_id: typing.Optional[str] = None,
         name: typing.Optional[str] = OMIT,
         account_id: typing.Optional[str] = OMIT,
+        app_override_id: typing.Optional[str] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> HttpResponse[Account]:
         """
@@ -166,6 +167,9 @@ def create(
         account_id : typing.Optional[str]
             An existing account ID to reconnect. When provided, the account's credentials are updated instead of creating a new account. Must belong to the same external user and project environment as the connect token, and match the app identified by app_slug.
 
+        app_override_id : typing.Optional[str]
+            An app override ID. The account is linked to the override and the override's pre-defined custom field values are merged over cfmap_json; with account_id, the account is re-linked to this override. Must belong to the app identified by app_slug, and must not select an OAuth client — overrides that do can only connect through the OAuth flow.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -187,6 +191,7 @@ def create(
                 "connect_token": connect_token,
                 "name": name,
                 "account_id": account_id,
+                "app_override_id": app_override_id,
             },
             headers={
                 "content-type": "application/json",
@@ -564,6 +569,7 @@ async def create(
         oauth_app_id: typing.Optional[str] = None,
         name: typing.Optional[str] = OMIT,
         account_id: typing.Optional[str] = OMIT,
+        app_override_id: typing.Optional[str] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> AsyncHttpResponse[Account]:
         """
@@ -591,6 +597,9 @@ async def create(
         account_id : typing.Optional[str]
             An existing account ID to reconnect. When provided, the account's credentials are updated instead of creating a new account. Must belong to the same external user and project environment as the connect token, and match the app identified by app_slug.
 
+        app_override_id : typing.Optional[str]
+            An app override ID. The account is linked to the override and the override's pre-defined custom field values are merged over cfmap_json; with account_id, the account is re-linked to this override. Must belong to the app identified by app_slug, and must not select an OAuth client — overrides that do can only connect through the OAuth flow.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -612,6 +621,7 @@ async def create(
                 "connect_token": connect_token,
                 "name": name,
                 "account_id": account_id,
+                "app_override_id": app_override_id,
             },
             headers={
                 "content-type": "application/json",

src/pipedream/core/client_wrapper.py

@@ -34,12 +34,12 @@ def get_headers(self) -> typing.Dict[str, str]:
         import platform
 
         headers: typing.Dict[str, str] = {
-            "User-Agent": "pipedream/2.1.19",
+            "User-Agent": "pipedream/2.1.20",
             "X-Fern-Language": "Python",
             "X-Fern-Runtime": f"python/{platform.python_version()}",
             "X-Fern-Platform": f"{platform.system().lower()}/{platform.release()}",
             "X-Fern-SDK-Name": "pipedream",
-            "X-Fern-SDK-Version": "2.1.19",
+            "X-Fern-SDK-Version": "2.1.20",
             **(self.get_custom_headers() or {}),
         }
         if self._project_environment is not None:

src/pipedream/tokens/client.py

@@ -39,6 +39,8 @@ def create(
         success_redirect_uri: typing.Optional[str] = OMIT,
         webhook_uri: typing.Optional[str] = OMIT,
         allow_progressive_scopes: typing.Optional[bool] = OMIT,
+        app_id: typing.Optional[str] = OMIT,
+        oauth_app_id: typing.Optional[str] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> CreateTokenResponse:
         """
@@ -70,6 +72,12 @@ def create(
         allow_progressive_scopes : typing.Optional[bool]
             When true, end users may authorize a subset of the app's OAuth scopes; only the app's functional scopes (needed for the post-OAuth test request) are enforced. Defaults to false.
 
+        app_id : typing.Optional[str]
+            Scope the Connect Link to this app, identified by app ID or name slug: resolves the app's official OAuth client for your workspace (when it has one) and pins the link to the host serving that client's OAuth flow pages. Optional.
+
+        oauth_app_id : typing.Optional[str]
+            Scope the Connect Link to a specific OAuth client (overrides app_id's resolution). Optional.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -100,6 +108,8 @@ def create(
             success_redirect_uri=success_redirect_uri,
             webhook_uri=webhook_uri,
             allow_progressive_scopes=allow_progressive_scopes,
+            app_id=app_id,
+            oauth_app_id=oauth_app_id,
             request_options=request_options,
         )
         return _response.data
@@ -108,9 +118,10 @@ def validate(
         self,
         ctok: ConnectToken,
         *,
-        app_id: str,
+        app_id: typing.Optional[str] = None,
         account_id: typing.Optional[str] = None,
         oauth_app_id: typing.Optional[str] = None,
+        app_override_id: typing.Optional[str] = None,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> ValidateTokenResponse:
         """
@@ -120,15 +131,18 @@ def validate(
         ----------
         ctok : ConnectToken
 
-        app_id : str
-            The app ID to validate against
+        app_id : typing.Optional[str]
+            The app ID to validate against. Required unless account_id or app_override_id identifies the app.
 
         account_id : typing.Optional[str]
             An existing account ID to reconnect. Must belong to the app identified by app_id.
 
         oauth_app_id : typing.Optional[str]
             The OAuth app ID to validate against (if the token is for an OAuth app)
 
+        app_override_id : typing.Optional[str]
+            An app override ID. Selects the override's app, pre-defined custom fields, and OAuth client. With account_id, re-links the account to this override; it must belong to the account's app, and an override that pins a different OAuth client switches the account to that client when the reconnect flow completes. A conflicting app_id or oauth_app_id is an error. To resolve an override by name, list them with GET /v1/connect/{project_id}/app_overrides and match on name.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -151,10 +165,16 @@ def validate(
             app_id="app_id",
             account_id="account_id",
             oauth_app_id="oauth_app_id",
+            app_override_id="app_override_id",
         )
         """
         _response = self._raw_client.validate(
-            ctok, app_id=app_id, account_id=account_id, oauth_app_id=oauth_app_id, request_options=request_options
+            ctok,
+            app_id=app_id,
+            account_id=account_id,
+            oauth_app_id=oauth_app_id,
+            app_override_id=app_override_id,
+            request_options=request_options,
         )
         return _response.data
 
@@ -185,6 +205,8 @@ async def create(
         success_redirect_uri: typing.Optional[str] = OMIT,
         webhook_uri: typing.Optional[str] = OMIT,
         allow_progressive_scopes: typing.Optional[bool] = OMIT,
+        app_id: typing.Optional[str] = OMIT,
+        oauth_app_id: typing.Optional[str] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> CreateTokenResponse:
         """
@@ -216,6 +238,12 @@ async def create(
         allow_progressive_scopes : typing.Optional[bool]
             When true, end users may authorize a subset of the app's OAuth scopes; only the app's functional scopes (needed for the post-OAuth test request) are enforced. Defaults to false.
 
+        app_id : typing.Optional[str]
+            Scope the Connect Link to this app, identified by app ID or name slug: resolves the app's official OAuth client for your workspace (when it has one) and pins the link to the host serving that client's OAuth flow pages. Optional.
+
+        oauth_app_id : typing.Optional[str]
+            Scope the Connect Link to a specific OAuth client (overrides app_id's resolution). Optional.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -254,6 +282,8 @@ async def main() -> None:
             success_redirect_uri=success_redirect_uri,
             webhook_uri=webhook_uri,
             allow_progressive_scopes=allow_progressive_scopes,
+            app_id=app_id,
+            oauth_app_id=oauth_app_id,
             request_options=request_options,
         )
         return _response.data
@@ -262,9 +292,10 @@ async def validate(
         self,
         ctok: ConnectToken,
         *,
-        app_id: str,
+        app_id: typing.Optional[str] = None,
         account_id: typing.Optional[str] = None,
         oauth_app_id: typing.Optional[str] = None,
+        app_override_id: typing.Optional[str] = None,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> ValidateTokenResponse:
         """
@@ -274,15 +305,18 @@ async def validate(
         ----------
         ctok : ConnectToken
 
-        app_id : str
-            The app ID to validate against
+        app_id : typing.Optional[str]
+            The app ID to validate against. Required unless account_id or app_override_id identifies the app.
 
         account_id : typing.Optional[str]
             An existing account ID to reconnect. Must belong to the app identified by app_id.
 
         oauth_app_id : typing.Optional[str]
             The OAuth app ID to validate against (if the token is for an OAuth app)
 
+        app_override_id : typing.Optional[str]
+            An app override ID. Selects the override's app, pre-defined custom fields, and OAuth client. With account_id, re-links the account to this override; it must belong to the account's app, and an override that pins a different OAuth client switches the account to that client when the reconnect flow completes. A conflicting app_id or oauth_app_id is an error. To resolve an override by name, list them with GET /v1/connect/{project_id}/app_overrides and match on name.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -310,12 +344,18 @@ async def main() -> None:
                 app_id="app_id",
                 account_id="account_id",
                 oauth_app_id="oauth_app_id",
+                app_override_id="app_override_id",
             )
 
 
         asyncio.run(main())
         """
         _response = await self._raw_client.validate(
-            ctok, app_id=app_id, account_id=account_id, oauth_app_id=oauth_app_id, request_options=request_options
+            ctok,
+            app_id=app_id,
+            account_id=account_id,
+            oauth_app_id=oauth_app_id,
+            app_override_id=app_override_id,
+            request_options=request_options,
         )
         return _response.data