diff --git a/README.md b/README.md index 36a4706..9bc8b61 100644 --- a/README.md +++ b/README.md @@ -24,7 +24,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -46,7 +46,7 @@ from pipedream import AsyncPipedream client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -87,7 +87,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/poetry.lock b/poetry.lock index a10276d..c1c2313 100644 --- a/poetry.lock +++ b/poetry.lock @@ -38,13 +38,13 @@ trio = ["trio (>=0.26.1)"] [[package]] name = "certifi" -version = "2025.7.9" +version = "2025.7.14" description = "Python package for providing Mozilla's CA Bundle." optional = false python-versions = ">=3.7" files = [ - {file = "certifi-2025.7.9-py3-none-any.whl", hash = "sha256:d842783a14f8fdd646895ac26f719a061408834473cfc10203f6a575beb15d39"}, - {file = "certifi-2025.7.9.tar.gz", hash = "sha256:c1d2ec05395148ee10cf672ffc28cd37ea0ab0d99f9cc74c43e588cbd111b079"}, + {file = "certifi-2025.7.14-py3-none-any.whl", hash = "sha256:6b31f564a415d79ee77df69d757bb49a5bb53bd9f756cbbe24394ffd6fc1f4b2"}, + {file = "certifi-2025.7.14.tar.gz", hash = "sha256:8ea99dbdfaaf2ba2f9bac77b9249ef62ec5218e7c2b2e903378ed5fccf765995"}, ] [[package]] diff --git a/pyproject.toml b/pyproject.toml index 820197e..61726ce 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -3,7 +3,7 @@ name = "pipedream" [tool.poetry] name = "pipedream" -version = "0.3.1" +version = "0.3.2" description = "" readme = "README.md" authors = [] diff --git a/reference.md b/reference.md index 6713ecd..d898404 100644 --- a/reference.md +++ b/reference.md @@ -17,7 +17,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -66,7 +66,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -126,7 +126,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -236,7 +236,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -296,7 +296,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -406,7 +406,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -515,7 +515,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -582,7 +582,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -641,7 +641,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -701,7 +701,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -761,7 +761,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -855,7 +855,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -914,7 +914,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -1055,7 +1055,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -1164,7 +1164,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -1258,7 +1258,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -1317,7 +1317,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -1458,7 +1458,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -1566,7 +1566,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -1659,7 +1659,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -1753,7 +1753,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -1812,7 +1812,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -1953,7 +1953,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2061,7 +2061,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2154,7 +2154,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2242,7 +2242,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2310,7 +2310,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2402,7 +2402,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2478,7 +2478,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2554,7 +2554,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2622,7 +2622,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2699,7 +2699,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2767,7 +2767,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2845,7 +2845,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2895,7 +2895,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -2972,7 +2972,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -3058,7 +3058,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -3144,7 +3144,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -3221,7 +3221,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -3308,7 +3308,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -3408,7 +3408,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -3476,7 +3476,7 @@ from pipedream import Pipedream client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/__init__.py b/src/pipedream/__init__.py index 09b017c..f626413 100644 --- a/src/pipedream/__init__.py +++ b/src/pipedream/__init__.py @@ -49,6 +49,7 @@ ListAppCategoriesResponse, ListAppsResponse, PageInfo, + ProjectEnvironment, ProjectInfoResponse, ProjectInfoResponseAppsItem, PropOption, @@ -131,6 +132,7 @@ "PageInfo", "Pipedream", "PipedreamEnvironment", + "ProjectEnvironment", "ProjectInfoResponse", "ProjectInfoResponseAppsItem", "PropOption", diff --git a/src/pipedream/accounts/client.py b/src/pipedream/accounts/client.py index c42be65..b0f86bf 100644 --- a/src/pipedream/accounts/client.py +++ b/src/pipedream/accounts/client.py @@ -76,7 +76,7 @@ def list( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -147,7 +147,7 @@ def create( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -198,7 +198,7 @@ def retrieve( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -230,7 +230,7 @@ def delete(self, account_id: str, *, request_options: typing.Optional[RequestOpt client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -260,7 +260,7 @@ def delete_by_app(self, app_id: str, *, request_options: typing.Optional[Request client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -338,7 +338,7 @@ async def list( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -418,7 +418,7 @@ async def create( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -477,7 +477,7 @@ async def retrieve( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -517,7 +517,7 @@ async def delete(self, account_id: str, *, request_options: typing.Optional[Requ client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -555,7 +555,7 @@ async def delete_by_app(self, app_id: str, *, request_options: typing.Optional[R client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/actions/client.py b/src/pipedream/actions/client.py index a5dd0d7..ad8161a 100644 --- a/src/pipedream/actions/client.py +++ b/src/pipedream/actions/client.py @@ -72,7 +72,7 @@ def list( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -108,7 +108,7 @@ def retrieve(self, component_id: str, *, request_options: typing.Optional[Reques client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -184,7 +184,7 @@ def configure_prop( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -259,7 +259,7 @@ def reload_props( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -321,7 +321,7 @@ def run( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -400,7 +400,7 @@ async def list( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -447,7 +447,7 @@ async def retrieve( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -531,7 +531,7 @@ async def configure_prop( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -614,7 +614,7 @@ async def reload_props( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -684,7 +684,7 @@ async def run( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/app_categories/client.py b/src/pipedream/app_categories/client.py index 1a15edd..ba55a1b 100644 --- a/src/pipedream/app_categories/client.py +++ b/src/pipedream/app_categories/client.py @@ -42,7 +42,7 @@ def list(self, *, request_options: typing.Optional[RequestOptions] = None) -> Li client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -72,7 +72,7 @@ def retrieve(self, id: str, *, request_options: typing.Optional[RequestOptions] client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -119,7 +119,7 @@ async def list(self, *, request_options: typing.Optional[RequestOptions] = None) client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -159,7 +159,7 @@ async def retrieve( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/apps/client.py b/src/pipedream/apps/client.py index 1256037..30d994c 100644 --- a/src/pipedream/apps/client.py +++ b/src/pipedream/apps/client.py @@ -77,7 +77,7 @@ def list( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -120,7 +120,7 @@ def retrieve(self, app_id: str, *, request_options: typing.Optional[RequestOptio client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -199,7 +199,7 @@ async def list( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -251,7 +251,7 @@ async def retrieve(self, app_id: str, *, request_options: typing.Optional[Reques client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/client.py b/src/pipedream/client.py index bb9de62..24d3539 100644 --- a/src/pipedream/client.py +++ b/src/pipedream/client.py @@ -4,6 +4,7 @@ import typing import httpx +from .types.project_environment import ProjectEnvironment from .accounts.client import AccountsClient, AsyncAccountsClient from .actions.client import ActionsClient, AsyncActionsClient from .app_categories.client import AppCategoriesClient, AsyncAppCategoriesClient @@ -41,7 +42,7 @@ class Client: project_id : str - x_pd_environment : typing.Optional[str] + project_environment : typing.Optional[ProjectEnvironment] client_id : typing.Optional[str] client_secret : typing.Optional[str] _token_getter_override : typing.Optional[typing.Callable[[], str]] @@ -60,7 +61,7 @@ class Client: client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -72,7 +73,7 @@ def __init__( base_url: typing.Optional[str] = None, environment: PipedreamEnvironment = PipedreamEnvironment.PROD, project_id: str, - x_pd_environment: typing.Optional[str] = None, + project_environment: typing.Optional[ProjectEnvironment] = os.getenv("PIPEDREAM_PROJECT_ENVIRONMENT"), client_id: typing.Optional[str] = os.getenv("PIPEDREAM_CLIENT_ID"), client_secret: typing.Optional[str] = os.getenv("PIPEDREAM_CLIENT_SECRET"), _token_getter_override: typing.Optional[typing.Callable[[], str]] = None, @@ -97,7 +98,7 @@ def __init__( client_wrapper=SyncClientWrapper( base_url=_get_base_url(base_url=base_url, environment=environment), project_id=project_id, - x_pd_environment=x_pd_environment, + project_environment=project_environment, httpx_client=httpx.Client(timeout=_defaulted_timeout, follow_redirects=follow_redirects) if follow_redirects is not None else httpx.Client(timeout=_defaulted_timeout), @@ -107,7 +108,7 @@ def __init__( self._client_wrapper = SyncClientWrapper( base_url=_get_base_url(base_url=base_url, environment=environment), project_id=project_id, - x_pd_environment=x_pd_environment, + project_environment=project_environment, token=_token_getter_override if _token_getter_override is not None else oauth_token_provider.get_token, httpx_client=httpx_client if httpx_client is not None @@ -149,7 +150,7 @@ class AsyncClient: project_id : str - x_pd_environment : typing.Optional[str] + project_environment : typing.Optional[ProjectEnvironment] client_id : typing.Optional[str] client_secret : typing.Optional[str] _token_getter_override : typing.Optional[typing.Callable[[], str]] @@ -168,7 +169,7 @@ class AsyncClient: client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -180,7 +181,7 @@ def __init__( base_url: typing.Optional[str] = None, environment: PipedreamEnvironment = PipedreamEnvironment.PROD, project_id: str, - x_pd_environment: typing.Optional[str] = None, + project_environment: typing.Optional[ProjectEnvironment] = os.getenv("PIPEDREAM_PROJECT_ENVIRONMENT"), client_id: typing.Optional[str] = os.getenv("PIPEDREAM_CLIENT_ID"), client_secret: typing.Optional[str] = os.getenv("PIPEDREAM_CLIENT_SECRET"), _token_getter_override: typing.Optional[typing.Callable[[], str]] = None, @@ -205,7 +206,7 @@ def __init__( client_wrapper=SyncClientWrapper( base_url=_get_base_url(base_url=base_url, environment=environment), project_id=project_id, - x_pd_environment=x_pd_environment, + project_environment=project_environment, httpx_client=httpx.Client(timeout=_defaulted_timeout, follow_redirects=follow_redirects) if follow_redirects is not None else httpx.Client(timeout=_defaulted_timeout), @@ -215,7 +216,7 @@ def __init__( self._client_wrapper = AsyncClientWrapper( base_url=_get_base_url(base_url=base_url, environment=environment), project_id=project_id, - x_pd_environment=x_pd_environment, + project_environment=project_environment, token=_token_getter_override if _token_getter_override is not None else oauth_token_provider.get_token, httpx_client=httpx_client if httpx_client is not None diff --git a/src/pipedream/components/client.py b/src/pipedream/components/client.py index 5df8730..f7fcbca 100644 --- a/src/pipedream/components/client.py +++ b/src/pipedream/components/client.py @@ -71,7 +71,7 @@ def list( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -107,7 +107,7 @@ def retrieve(self, component_id: str, *, request_options: typing.Optional[Reques client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -183,7 +183,7 @@ def configure_prop( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -258,7 +258,7 @@ def reload_props( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -339,7 +339,7 @@ async def list( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -386,7 +386,7 @@ async def retrieve( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -470,7 +470,7 @@ async def configure_prop( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -553,7 +553,7 @@ async def reload_props( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/core/client_wrapper.py b/src/pipedream/core/client_wrapper.py index 1dcf256..5cbb73a 100644 --- a/src/pipedream/core/client_wrapper.py +++ b/src/pipedream/core/client_wrapper.py @@ -3,6 +3,7 @@ import typing import httpx +from ..types.project_environment import ProjectEnvironment from .http_client import AsyncHttpClient, HttpClient @@ -11,14 +12,14 @@ def __init__( self, *, project_id: str, - x_pd_environment: typing.Optional[str] = None, + project_environment: typing.Optional[ProjectEnvironment] = None, token: typing.Optional[typing.Union[str, typing.Callable[[], str]]] = None, headers: typing.Optional[typing.Dict[str, str]] = None, base_url: str, timeout: typing.Optional[float] = None, ): self._project_id = project_id - self._x_pd_environment = x_pd_environment + self._project_environment = project_environment self._token = token self._headers = headers self._base_url = base_url @@ -26,14 +27,14 @@ def __init__( def get_headers(self) -> typing.Dict[str, str]: headers: typing.Dict[str, str] = { - "User-Agent": "pipedream/0.3.1", + "User-Agent": "pipedream/0.3.2", "X-Fern-Language": "Python", "X-Fern-SDK-Name": "pipedream", - "X-Fern-SDK-Version": "0.3.1", + "X-Fern-SDK-Version": "0.3.2", **(self.get_custom_headers() or {}), } - if self._x_pd_environment is not None: - headers["x-pd-environment"] = self._x_pd_environment + if self._project_environment is not None: + headers["x-pd-environment"] = self._project_environment token = self._get_token() if token is not None: headers["Authorization"] = f"Bearer {token}" @@ -60,7 +61,7 @@ def __init__( self, *, project_id: str, - x_pd_environment: typing.Optional[str] = None, + project_environment: typing.Optional[ProjectEnvironment] = None, token: typing.Optional[typing.Union[str, typing.Callable[[], str]]] = None, headers: typing.Optional[typing.Dict[str, str]] = None, base_url: str, @@ -69,7 +70,7 @@ def __init__( ): super().__init__( project_id=project_id, - x_pd_environment=x_pd_environment, + project_environment=project_environment, token=token, headers=headers, base_url=base_url, @@ -88,7 +89,7 @@ def __init__( self, *, project_id: str, - x_pd_environment: typing.Optional[str] = None, + project_environment: typing.Optional[ProjectEnvironment] = None, token: typing.Optional[typing.Union[str, typing.Callable[[], str]]] = None, headers: typing.Optional[typing.Dict[str, str]] = None, base_url: str, @@ -97,7 +98,7 @@ def __init__( ): super().__init__( project_id=project_id, - x_pd_environment=x_pd_environment, + project_environment=project_environment, token=token, headers=headers, base_url=base_url, diff --git a/src/pipedream/deployed_triggers/client.py b/src/pipedream/deployed_triggers/client.py index 8482f8e..dd6c23f 100644 --- a/src/pipedream/deployed_triggers/client.py +++ b/src/pipedream/deployed_triggers/client.py @@ -68,7 +68,7 @@ def list( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -110,7 +110,7 @@ def retrieve( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -165,7 +165,7 @@ def update( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -216,7 +216,7 @@ def delete( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -266,7 +266,7 @@ def list_events( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -305,7 +305,7 @@ def list_workflows( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -352,7 +352,7 @@ def update_workflows( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -392,7 +392,7 @@ def list_webhooks( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -439,7 +439,7 @@ def update_webhooks( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -510,7 +510,7 @@ async def list( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -561,7 +561,7 @@ async def retrieve( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -624,7 +624,7 @@ async def update( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -683,7 +683,7 @@ async def delete( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -741,7 +741,7 @@ async def list_events( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -788,7 +788,7 @@ async def list_workflows( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -843,7 +843,7 @@ async def update_workflows( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -891,7 +891,7 @@ async def list_webhooks( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -946,7 +946,7 @@ async def update_webhooks( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/oauth_tokens/client.py b/src/pipedream/oauth_tokens/client.py index bd891f1..19a4a39 100644 --- a/src/pipedream/oauth_tokens/client.py +++ b/src/pipedream/oauth_tokens/client.py @@ -50,7 +50,7 @@ def create( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -106,7 +106,7 @@ async def create( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/pipedream.py b/src/pipedream/pipedream.py index 86959a4..9a40dbf 100644 --- a/src/pipedream/pipedream.py +++ b/src/pipedream/pipedream.py @@ -1,14 +1,12 @@ import os -from typing import ( - Literal, - Optional, -) +from typing import Optional from .client import ( AsyncClient, Client, ) from .environment import PipedreamEnvironment +from .types.project_environment import ProjectEnvironment class OAuthCredentials: @@ -30,8 +28,8 @@ def __init__( *, credentials: OAuthCredentials = OAuthCredentials(), project_id: Optional[str] = None, - environment: Literal["production", "development"] = "production", - api_environment: PipedreamEnvironment = PipedreamEnvironment.PROD, + project_environment: ProjectEnvironment = "production", + environment: PipedreamEnvironment = PipedreamEnvironment.PROD, **kwargs, ): project_id = project_id or os.getenv("PIPEDREAM_PROJECT_ID") @@ -39,11 +37,11 @@ def __init__( raise ValueError("Project ID is required") super().__init__( - base_url=_get_base_url(api_environment), + base_url=_get_base_url(environment), client_id=credentials.client_id, client_secret=credentials.client_secret, project_id=project_id, - x_pd_environment=environment, + project_environment=project_environment, **kwargs, ) @@ -55,8 +53,8 @@ def __init__( *, credentials: OAuthCredentials = OAuthCredentials(), project_id: Optional[str] = None, - environment: Literal["production", "development"] = "production", - api_environment: PipedreamEnvironment = PipedreamEnvironment.PROD, + project_environment: ProjectEnvironment = "production", + environment: PipedreamEnvironment = PipedreamEnvironment.PROD, **kwargs, ): project_id = project_id or os.getenv("PIPEDREAM_PROJECT_ID") @@ -64,11 +62,11 @@ def __init__( raise ValueError("Project ID is required") super().__init__( - base_url=_get_base_url(api_environment), + base_url=_get_base_url(environment), client_id=credentials.client_id, client_secret=credentials.client_secret, project_id=project_id, - x_pd_environment=environment, + project_environment=project_environment, **kwargs, ) diff --git a/src/pipedream/projects/client.py b/src/pipedream/projects/client.py index cb6cf35..8ea3273 100644 --- a/src/pipedream/projects/client.py +++ b/src/pipedream/projects/client.py @@ -41,7 +41,7 @@ def retrieve_info(self, *, request_options: typing.Optional[RequestOptions] = No client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -86,7 +86,7 @@ async def retrieve_info(self, *, request_options: typing.Optional[RequestOptions client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/proxy/client.py b/src/pipedream/proxy/client.py index 7eca883..fe2d96b 100644 --- a/src/pipedream/proxy/client.py +++ b/src/pipedream/proxy/client.py @@ -59,7 +59,7 @@ def get( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -111,7 +111,7 @@ def post( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -168,7 +168,7 @@ def put( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -222,7 +222,7 @@ def delete( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -274,7 +274,7 @@ def patch( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -346,7 +346,7 @@ async def get( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -406,7 +406,7 @@ async def post( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -471,7 +471,7 @@ async def put( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -533,7 +533,7 @@ async def delete( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -593,7 +593,7 @@ async def patch( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/tokens/client.py b/src/pipedream/tokens/client.py index 2477a45..f29691c 100644 --- a/src/pipedream/tokens/client.py +++ b/src/pipedream/tokens/client.py @@ -74,7 +74,7 @@ def create( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -122,7 +122,7 @@ def validate( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -197,7 +197,7 @@ async def create( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -253,7 +253,7 @@ async def validate( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/triggers/client.py b/src/pipedream/triggers/client.py index 025ca01..f3ea70e 100644 --- a/src/pipedream/triggers/client.py +++ b/src/pipedream/triggers/client.py @@ -72,7 +72,7 @@ def list( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -108,7 +108,7 @@ def retrieve(self, component_id: str, *, request_options: typing.Optional[Reques client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -184,7 +184,7 @@ def configure_prop( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -259,7 +259,7 @@ def reload_props( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -322,7 +322,7 @@ def deploy( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -401,7 +401,7 @@ async def list( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -448,7 +448,7 @@ async def retrieve( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -532,7 +532,7 @@ async def configure_prop( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -615,7 +615,7 @@ async def reload_props( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -686,7 +686,7 @@ async def deploy( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) diff --git a/src/pipedream/types/__init__.py b/src/pipedream/types/__init__.py index c0604e5..fc63eed 100644 --- a/src/pipedream/types/__init__.py +++ b/src/pipedream/types/__init__.py @@ -48,6 +48,7 @@ from .list_app_categories_response import ListAppCategoriesResponse from .list_apps_response import ListAppsResponse from .page_info import PageInfo +from .project_environment import ProjectEnvironment from .project_info_response import ProjectInfoResponse from .project_info_response_apps_item import ProjectInfoResponseAppsItem from .prop_option import PropOption @@ -106,6 +107,7 @@ "ListAppCategoriesResponse", "ListAppsResponse", "PageInfo", + "ProjectEnvironment", "ProjectInfoResponse", "ProjectInfoResponseAppsItem", "PropOption", diff --git a/src/pipedream/types/project_environment.py b/src/pipedream/types/project_environment.py new file mode 100644 index 0000000..ddf9d3a --- /dev/null +++ b/src/pipedream/types/project_environment.py @@ -0,0 +1,5 @@ +# This file was auto-generated by Fern from our API Definition. + +import typing + +ProjectEnvironment = typing.Union[typing.Literal["development", "production"], typing.Any] diff --git a/src/pipedream/users/client.py b/src/pipedream/users/client.py index de3cb50..e3862a5 100644 --- a/src/pipedream/users/client.py +++ b/src/pipedream/users/client.py @@ -43,7 +43,7 @@ def delete_external_user( client = Pipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", ) @@ -93,7 +93,7 @@ async def delete_external_user( client = AsyncPipedream( project_id="YOUR_PROJECT_ID", - x_pd_environment="YOUR_X_PD_ENVIRONMENT", + project_environment="YOUR_PROJECT_ENVIRONMENT", client_id="YOUR_CLIENT_ID", client_secret="YOUR_CLIENT_SECRET", )