Skip to content

Commit c9360c4

Browse files
fern-api[bot]fern-api[bot]
authored
SDK regeneration
1 parent c4faac0 commit c9360c4

File tree

10 files changed

+122
-48
lines changed

10 files changed

+122
-48
lines changed

‎poetry.lock‎

Lines changed: 47 additions & 37 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎pyproject.toml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ name = "pipedream"
33

44
[tool.poetry]
55
name = "pipedream"
6-
version = "1.0.9"
6+
version = "1.0.10"
77
description = ""
88
readme = "README.md"
99
authors = []

‎src/pipedream/client.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import typing
77

88
import httpx
9-
from .types.project_environment import ProjectEnvironment
9+
from ._.types.project_environment import ProjectEnvironment
1010
from .core.api_error import ApiError
1111
from .core.client_wrapper import AsyncClientWrapper, SyncClientWrapper
1212
from .core.oauth_token_provider import OAuthTokenProvider

‎src/pipedream/core/client_wrapper.py‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import typing
44

55
import httpx
6-
from ..types.project_environment import ProjectEnvironment
6+
from .._.types.project_environment import ProjectEnvironment
77
from .http_client import AsyncHttpClient, HttpClient
88

99

@@ -27,10 +27,10 @@ def __init__(
2727

2828
def get_headers(self) -> typing.Dict[str, str]:
2929
headers: typing.Dict[str, str] = {
30-
"User-Agent": "pipedream/1.0.9",
30+
"User-Agent": "pipedream/1.0.10",
3131
"X-Fern-Language": "Python",
3232
"X-Fern-SDK-Name": "pipedream",
33-
"X-Fern-SDK-Version": "1.0.9",
33+
"X-Fern-SDK-Version": "1.0.10",
3434
**(self.get_custom_headers() or {}),
3535
}
3636
if self._project_environment is not None:

‎src/pipedream/oauth_tokens/client.py‎

Lines changed: 20 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,12 @@ def with_raw_response(self) -> RawOauthTokensClient:
2727
return self._raw_client
2828

2929
def create(
30-
self, *, client_id: str, client_secret: str, request_options: typing.Optional[RequestOptions] = None
30+
self,
31+
*,
32+
client_id: str,
33+
client_secret: str,
34+
scope: typing.Optional[str] = OMIT,
35+
request_options: typing.Optional[RequestOptions] = None,
3136
) -> CreateOAuthTokenResponse:
3237
"""
3338
Exchange OAuth credentials for an access token
@@ -38,6 +43,9 @@ def create(
3843
3944
client_secret : str
4045
46+
scope : typing.Optional[str]
47+
Optional space-separated scopes for the access token. Defaults to '*'.
48+
4149
request_options : typing.Optional[RequestOptions]
4250
Request-specific configuration.
4351
@@ -62,7 +70,7 @@ def create(
6270
)
6371
"""
6472
_response = self._raw_client.create(
65-
client_id=client_id, client_secret=client_secret, request_options=request_options
73+
client_id=client_id, client_secret=client_secret, scope=scope, request_options=request_options
6674
)
6775
return _response.data
6876

@@ -83,7 +91,12 @@ def with_raw_response(self) -> AsyncRawOauthTokensClient:
8391
return self._raw_client
8492

8593
async def create(
86-
self, *, client_id: str, client_secret: str, request_options: typing.Optional[RequestOptions] = None
94+
self,
95+
*,
96+
client_id: str,
97+
client_secret: str,
98+
scope: typing.Optional[str] = OMIT,
99+
request_options: typing.Optional[RequestOptions] = None,
87100
) -> CreateOAuthTokenResponse:
88101
"""
89102
Exchange OAuth credentials for an access token
@@ -94,6 +107,9 @@ async def create(
94107
95108
client_secret : str
96109
110+
scope : typing.Optional[str]
111+
Optional space-separated scopes for the access token. Defaults to '*'.
112+
97113
request_options : typing.Optional[RequestOptions]
98114
Request-specific configuration.
99115
@@ -126,6 +142,6 @@ async def main() -> None:
126142
asyncio.run(main())
127143
"""
128144
_response = await self._raw_client.create(
129-
client_id=client_id, client_secret=client_secret, request_options=request_options
145+
client_id=client_id, client_secret=client_secret, scope=scope, request_options=request_options
130146
)
131147
return _response.data

‎src/pipedream/oauth_tokens/raw_client.py‎

Lines changed: 20 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,12 @@ def __init__(self, *, client_wrapper: SyncClientWrapper):
1919
self._client_wrapper = client_wrapper
2020

2121
def create(
22-
self, *, client_id: str, client_secret: str, request_options: typing.Optional[RequestOptions] = None
22+
self,
23+
*,
24+
client_id: str,
25+
client_secret: str,
26+
scope: typing.Optional[str] = OMIT,
27+
request_options: typing.Optional[RequestOptions] = None,
2328
) -> HttpResponse[CreateOAuthTokenResponse]:
2429
"""
2530
Exchange OAuth credentials for an access token
@@ -30,6 +35,9 @@ def create(
3035
3136
client_secret : str
3237
38+
scope : typing.Optional[str]
39+
Optional space-separated scopes for the access token. Defaults to '*'.
40+
3341
request_options : typing.Optional[RequestOptions]
3442
Request-specific configuration.
3543
@@ -44,6 +52,7 @@ def create(
4452
json={
4553
"client_id": client_id,
4654
"client_secret": client_secret,
55+
"scope": scope,
4756
"grant_type": "client_credentials",
4857
},
4958
headers={
@@ -73,7 +82,12 @@ def __init__(self, *, client_wrapper: AsyncClientWrapper):
7382
self._client_wrapper = client_wrapper
7483

7584
async def create(
76-
self, *, client_id: str, client_secret: str, request_options: typing.Optional[RequestOptions] = None
85+
self,
86+
*,
87+
client_id: str,
88+
client_secret: str,
89+
scope: typing.Optional[str] = OMIT,
90+
request_options: typing.Optional[RequestOptions] = None,
7791
) -> AsyncHttpResponse[CreateOAuthTokenResponse]:
7892
"""
7993
Exchange OAuth credentials for an access token
@@ -84,6 +98,9 @@ async def create(
8498
8599
client_secret : str
86100
101+
scope : typing.Optional[str]
102+
Optional space-separated scopes for the access token. Defaults to '*'.
103+
87104
request_options : typing.Optional[RequestOptions]
88105
Request-specific configuration.
89106
@@ -98,6 +115,7 @@ async def create(
98115
json={
99116
"client_id": client_id,
100117
"client_secret": client_secret,
118+
"scope": scope,
101119
"grant_type": "client_credentials",
102120
},
103121
headers={

‎src/pipedream/triggers/client.py‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -282,6 +282,7 @@ def deploy(
282282
external_user_id: str,
283283
configured_props: typing.Optional[ConfiguredProps] = OMIT,
284284
dynamic_props_id: typing.Optional[str] = OMIT,
285+
workflow_id: typing.Optional[str] = OMIT,
285286
webhook_url: typing.Optional[str] = OMIT,
286287
request_options: typing.Optional[RequestOptions] = None,
287288
) -> DeployTriggerResponseData:
@@ -301,6 +302,9 @@ def deploy(
301302
dynamic_props_id : typing.Optional[str]
302303
The ID for dynamic props
303304
305+
workflow_id : typing.Optional[str]
306+
Optional ID of a workflow to receive trigger events
307+
304308
webhook_url : typing.Optional[str]
305309
Optional webhook URL to receive trigger events
306310
@@ -332,6 +336,7 @@ def deploy(
332336
external_user_id=external_user_id,
333337
configured_props=configured_props,
334338
dynamic_props_id=dynamic_props_id,
339+
workflow_id=workflow_id,
335340
webhook_url=webhook_url,
336341
request_options=request_options,
337342
)
@@ -639,6 +644,7 @@ async def deploy(
639644
external_user_id: str,
640645
configured_props: typing.Optional[ConfiguredProps] = OMIT,
641646
dynamic_props_id: typing.Optional[str] = OMIT,
647+
workflow_id: typing.Optional[str] = OMIT,
642648
webhook_url: typing.Optional[str] = OMIT,
643649
request_options: typing.Optional[RequestOptions] = None,
644650
) -> DeployTriggerResponseData:
@@ -658,6 +664,9 @@ async def deploy(
658664
dynamic_props_id : typing.Optional[str]
659665
The ID for dynamic props
660666
667+
workflow_id : typing.Optional[str]
668+
Optional ID of a workflow to receive trigger events
669+
661670
webhook_url : typing.Optional[str]
662671
Optional webhook URL to receive trigger events
663672
@@ -697,6 +706,7 @@ async def main() -> None:
697706
external_user_id=external_user_id,
698707
configured_props=configured_props,
699708
dynamic_props_id=dynamic_props_id,
709+
workflow_id=workflow_id,
700710
webhook_url=webhook_url,
701711
request_options=request_options,
702712
)

0 commit comments

Comments
 (0)