Skip to content

Commit 8a8fac8

Browse files
committed
Update custom client to the new args
1 parent c685362 commit 8a8fac8

File tree

1 file changed

+10
-12
lines changed

1 file changed

+10
-12
lines changed

src/pipedream/pipedream.py

Lines changed: 10 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,12 @@
11
import os
2-
from typing import (
3-
Literal,
4-
Optional,
5-
)
2+
from typing import Optional
63

74
from .client import (
85
AsyncClient,
96
Client,
107
)
118
from .environment import PipedreamEnvironment
9+
from .types.project_environment import ProjectEnvironment
1210

1311

1412
class OAuthCredentials:
@@ -30,20 +28,20 @@ def __init__(
3028
*,
3129
credentials: OAuthCredentials = OAuthCredentials(),
3230
project_id: Optional[str] = None,
33-
environment: Literal["production", "development"] = "production",
34-
api_environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
31+
project_environment: ProjectEnvironment = "production",
32+
environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
3533
**kwargs,
3634
):
3735
project_id = project_id or os.getenv("PIPEDREAM_PROJECT_ID")
3836
if not project_id:
3937
raise ValueError("Project ID is required")
4038

4139
super().__init__(
42-
base_url=_get_base_url(api_environment),
40+
base_url=_get_base_url(environment),
4341
client_id=credentials.client_id,
4442
client_secret=credentials.client_secret,
4543
project_id=project_id,
46-
x_pd_environment=environment,
44+
project_environment=project_environment,
4745
**kwargs,
4846
)
4947

@@ -55,20 +53,20 @@ def __init__(
5553
*,
5654
credentials: OAuthCredentials = OAuthCredentials(),
5755
project_id: Optional[str] = None,
58-
environment: Literal["production", "development"] = "production",
59-
api_environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
56+
project_environment: ProjectEnvironment = "production",
57+
environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
6058
**kwargs,
6159
):
6260
project_id = project_id or os.getenv("PIPEDREAM_PROJECT_ID")
6361
if not project_id:
6462
raise ValueError("Project ID is required")
6563

6664
super().__init__(
67-
base_url=_get_base_url(api_environment),
65+
base_url=_get_base_url(environment),
6866
client_id=credentials.client_id,
6967
client_secret=credentials.client_secret,
7068
project_id=project_id,
71-
x_pd_environment=environment,
69+
project_environment=project_environment,
7270
**kwargs,
7371
)
7472

0 commit comments

Comments
 (0)