Skip to content

Commit c4a57b9

Browse files
fern-api[bot]fern-api[bot]
authored
SDK regeneration
1 parent 0ff0d74 commit c4a57b9

21 files changed

+261
-83
lines changed

‎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.10"
6+
version = "1.0.11"
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.10",
30+
"User-Agent": "pipedream/1.0.11",
3131
"X-Fern-Language": "Python",
3232
"X-Fern-SDK-Name": "pipedream",
33-
"X-Fern-SDK-Version": "1.0.10",
33+
"X-Fern-SDK-Version": "1.0.11",
3434
**(self.get_custom_headers() or {}),
3535
}
3636
if self._project_environment is not None:

‎src/pipedream/deployed_triggers/client.py‎

Lines changed: 36 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,9 @@
66
from ..core.pagination import AsyncPager, SyncPager
77
from ..core.request_options import RequestOptions
88
from ..types.configured_props import ConfiguredProps
9-
from ..types.deployed_component import DeployedComponent
109
from ..types.emitted_event import EmittedEvent
11-
from ..types.get_trigger_response_data import GetTriggerResponseData
10+
from ..types.emitter import Emitter
11+
from ..types.emitter_type import EmitterType
1212
from ..types.get_trigger_webhooks_response import GetTriggerWebhooksResponse
1313
from ..types.get_trigger_workflows_response import GetTriggerWorkflowsResponse
1414
from .raw_client import AsyncRawDeployedTriggersClient, RawDeployedTriggersClient
@@ -39,8 +39,9 @@ def list(
3939
after: typing.Optional[str] = None,
4040
before: typing.Optional[str] = None,
4141
limit: typing.Optional[int] = None,
42+
emitter_type: typing.Optional[EmitterType] = None,
4243
request_options: typing.Optional[RequestOptions] = None,
43-
) -> SyncPager[DeployedComponent]:
44+
) -> SyncPager[Emitter]:
4445
"""
4546
Retrieve all deployed triggers for a specific external user
4647
@@ -58,12 +59,15 @@ def list(
5859
limit : typing.Optional[int]
5960
The maximum number of results to return
6061
62+
emitter_type : typing.Optional[EmitterType]
63+
Filter deployed triggers by emitter type (defaults to 'source' if not provided)
64+
6165
request_options : typing.Optional[RequestOptions]
6266
Request-specific configuration.
6367
6468
Returns
6569
-------
66-
SyncPager[DeployedComponent]
70+
SyncPager[Emitter]
6771
deployed triggers listed
6872
6973
Examples
@@ -81,6 +85,7 @@ def list(
8185
before="before",
8286
limit=1,
8387
external_user_id="external_user_id",
88+
emitter_type="email",
8489
)
8590
for item in response:
8691
yield item
@@ -89,12 +94,17 @@ def list(
8994
yield page
9095
"""
9196
return self._raw_client.list(
92-
external_user_id=external_user_id, after=after, before=before, limit=limit, request_options=request_options
97+
external_user_id=external_user_id,
98+
after=after,
99+
before=before,
100+
limit=limit,
101+
emitter_type=emitter_type,
102+
request_options=request_options,
93103
)
94104

95105
def retrieve(
96106
self, trigger_id: str, *, external_user_id: str, request_options: typing.Optional[RequestOptions] = None
97-
) -> GetTriggerResponseData:
107+
) -> Emitter:
98108
"""
99109
Get details of a specific deployed trigger by its ID
100110
@@ -110,7 +120,7 @@ def retrieve(
110120
111121
Returns
112122
-------
113-
GetTriggerResponseData
123+
Emitter
114124
deployed trigger retrieved
115125
116126
Examples
@@ -142,7 +152,7 @@ def update(
142152
configured_props: typing.Optional[ConfiguredProps] = OMIT,
143153
name: typing.Optional[str] = OMIT,
144154
request_options: typing.Optional[RequestOptions] = None,
145-
) -> GetTriggerResponseData:
155+
) -> Emitter:
146156
"""
147157
Modify the configuration of a deployed trigger, including active status
148158
@@ -166,7 +176,7 @@ def update(
166176
167177
Returns
168178
-------
169-
GetTriggerResponseData
179+
Emitter
170180
deployed trigger updated
171181
172182
Examples
@@ -501,8 +511,9 @@ async def list(
501511
after: typing.Optional[str] = None,
502512
before: typing.Optional[str] = None,
503513
limit: typing.Optional[int] = None,
514+
emitter_type: typing.Optional[EmitterType] = None,
504515
request_options: typing.Optional[RequestOptions] = None,
505-
) -> AsyncPager[DeployedComponent]:
516+
) -> AsyncPager[Emitter]:
506517
"""
507518
Retrieve all deployed triggers for a specific external user
508519
@@ -520,12 +531,15 @@ async def list(
520531
limit : typing.Optional[int]
521532
The maximum number of results to return
522533
534+
emitter_type : typing.Optional[EmitterType]
535+
Filter deployed triggers by emitter type (defaults to 'source' if not provided)
536+
523537
request_options : typing.Optional[RequestOptions]
524538
Request-specific configuration.
525539
526540
Returns
527541
-------
528-
AsyncPager[DeployedComponent]
542+
AsyncPager[Emitter]
529543
deployed triggers listed
530544
531545
Examples
@@ -548,6 +562,7 @@ async def main() -> None:
548562
before="before",
549563
limit=1,
550564
external_user_id="external_user_id",
565+
emitter_type="email",
551566
)
552567
async for item in response:
553568
yield item
@@ -560,12 +575,17 @@ async def main() -> None:
560575
asyncio.run(main())
561576
"""
562577
return await self._raw_client.list(
563-
external_user_id=external_user_id, after=after, before=before, limit=limit, request_options=request_options
578+
external_user_id=external_user_id,
579+
after=after,
580+
before=before,
581+
limit=limit,
582+
emitter_type=emitter_type,
583+
request_options=request_options,
564584
)
565585

566586
async def retrieve(
567587
self, trigger_id: str, *, external_user_id: str, request_options: typing.Optional[RequestOptions] = None
568-
) -> GetTriggerResponseData:
588+
) -> Emitter:
569589
"""
570590
Get details of a specific deployed trigger by its ID
571591
@@ -581,7 +601,7 @@ async def retrieve(
581601
582602
Returns
583603
-------
584-
GetTriggerResponseData
604+
Emitter
585605
deployed trigger retrieved
586606
587607
Examples
@@ -621,7 +641,7 @@ async def update(
621641
configured_props: typing.Optional[ConfiguredProps] = OMIT,
622642
name: typing.Optional[str] = OMIT,
623643
request_options: typing.Optional[RequestOptions] = None,
624-
) -> GetTriggerResponseData:
644+
) -> Emitter:
625645
"""
626646
Modify the configuration of a deployed trigger, including active status
627647
@@ -645,7 +665,7 @@ async def update(
645665
646666
Returns
647667
-------
648-
GetTriggerResponseData
668+
Emitter
649669
deployed trigger updated
650670
651671
Examples

‎src/pipedream/deployed_triggers/raw_client.py‎

Lines changed: 26 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -13,11 +13,11 @@
1313
from ..core.serialization import convert_and_respect_annotation_metadata
1414
from ..errors.too_many_requests_error import TooManyRequestsError
1515
from ..types.configured_props import ConfiguredProps
16-
from ..types.deployed_component import DeployedComponent
1716
from ..types.emitted_event import EmittedEvent
17+
from ..types.emitter import Emitter
18+
from ..types.emitter_type import EmitterType
1819
from ..types.get_trigger_events_response import GetTriggerEventsResponse
1920
from ..types.get_trigger_response import GetTriggerResponse
20-
from ..types.get_trigger_response_data import GetTriggerResponseData
2121
from ..types.get_trigger_webhooks_response import GetTriggerWebhooksResponse
2222
from ..types.get_trigger_workflows_response import GetTriggerWorkflowsResponse
2323
from ..types.get_triggers_response import GetTriggersResponse
@@ -37,8 +37,9 @@ def list(
3737
after: typing.Optional[str] = None,
3838
before: typing.Optional[str] = None,
3939
limit: typing.Optional[int] = None,
40+
emitter_type: typing.Optional[EmitterType] = None,
4041
request_options: typing.Optional[RequestOptions] = None,
41-
) -> SyncPager[DeployedComponent]:
42+
) -> SyncPager[Emitter]:
4243
"""
4344
Retrieve all deployed triggers for a specific external user
4445
@@ -56,12 +57,15 @@ def list(
5657
limit : typing.Optional[int]
5758
The maximum number of results to return
5859
60+
emitter_type : typing.Optional[EmitterType]
61+
Filter deployed triggers by emitter type (defaults to 'source' if not provided)
62+
5963
request_options : typing.Optional[RequestOptions]
6064
Request-specific configuration.
6165
6266
Returns
6367
-------
64-
SyncPager[DeployedComponent]
68+
SyncPager[Emitter]
6569
deployed triggers listed
6670
"""
6771
_response = self._client_wrapper.httpx_client.request(
@@ -72,6 +76,7 @@ def list(
7276
"before": before,
7377
"limit": limit,
7478
"external_user_id": external_user_id,
79+
"emitter_type": emitter_type,
7580
},
7681
request_options=request_options,
7782
)
@@ -95,6 +100,7 @@ def list(
95100
after=_parsed_next,
96101
before=before,
97102
limit=limit,
103+
emitter_type=emitter_type,
98104
request_options=request_options,
99105
)
100106
return SyncPager(
@@ -118,7 +124,7 @@ def list(
118124

119125
def retrieve(
120126
self, trigger_id: str, *, external_user_id: str, request_options: typing.Optional[RequestOptions] = None
121-
) -> HttpResponse[GetTriggerResponseData]:
127+
) -> HttpResponse[Emitter]:
122128
"""
123129
Get details of a specific deployed trigger by its ID
124130
@@ -134,7 +140,7 @@ def retrieve(
134140
135141
Returns
136142
-------
137-
HttpResponse[GetTriggerResponseData]
143+
HttpResponse[Emitter]
138144
deployed trigger retrieved
139145
"""
140146
_response = self._client_wrapper.httpx_client.request(
@@ -181,7 +187,7 @@ def update(
181187
configured_props: typing.Optional[ConfiguredProps] = OMIT,
182188
name: typing.Optional[str] = OMIT,
183189
request_options: typing.Optional[RequestOptions] = None,
184-
) -> HttpResponse[GetTriggerResponseData]:
190+
) -> HttpResponse[Emitter]:
185191
"""
186192
Modify the configuration of a deployed trigger, including active status
187193
@@ -205,7 +211,7 @@ def update(
205211
206212
Returns
207213
-------
208-
HttpResponse[GetTriggerResponseData]
214+
HttpResponse[Emitter]
209215
deployed trigger updated
210216
"""
211217
_response = self._client_wrapper.httpx_client.request(
@@ -637,8 +643,9 @@ async def list(
637643
after: typing.Optional[str] = None,
638644
before: typing.Optional[str] = None,
639645
limit: typing.Optional[int] = None,
646+
emitter_type: typing.Optional[EmitterType] = None,
640647
request_options: typing.Optional[RequestOptions] = None,
641-
) -> AsyncPager[DeployedComponent]:
648+
) -> AsyncPager[Emitter]:
642649
"""
643650
Retrieve all deployed triggers for a specific external user
644651
@@ -656,12 +663,15 @@ async def list(
656663
limit : typing.Optional[int]
657664
The maximum number of results to return
658665
666+
emitter_type : typing.Optional[EmitterType]
667+
Filter deployed triggers by emitter type (defaults to 'source' if not provided)
668+
659669
request_options : typing.Optional[RequestOptions]
660670
Request-specific configuration.
661671
662672
Returns
663673
-------
664-
AsyncPager[DeployedComponent]
674+
AsyncPager[Emitter]
665675
deployed triggers listed
666676
"""
667677
_response = await self._client_wrapper.httpx_client.request(
@@ -672,6 +682,7 @@ async def list(
672682
"before": before,
673683
"limit": limit,
674684
"external_user_id": external_user_id,
685+
"emitter_type": emitter_type,
675686
},
676687
request_options=request_options,
677688
)
@@ -697,6 +708,7 @@ async def _get_next():
697708
after=_parsed_next,
698709
before=before,
699710
limit=limit,
711+
emitter_type=emitter_type,
700712
request_options=request_options,
701713
)
702714

@@ -721,7 +733,7 @@ async def _get_next():
721733

722734
async def retrieve(
723735
self, trigger_id: str, *, external_user_id: str, request_options: typing.Optional[RequestOptions] = None
724-
) -> AsyncHttpResponse[GetTriggerResponseData]:
736+
) -> AsyncHttpResponse[Emitter]:
725737
"""
726738
Get details of a specific deployed trigger by its ID
727739
@@ -737,7 +749,7 @@ async def retrieve(
737749
738750
Returns
739751
-------
740-
AsyncHttpResponse[GetTriggerResponseData]
752+
AsyncHttpResponse[Emitter]
741753
deployed trigger retrieved
742754
"""
743755
_response = await self._client_wrapper.httpx_client.request(
@@ -784,7 +796,7 @@ async def update(
784796
configured_props: typing.Optional[ConfiguredProps] = OMIT,
785797
name: typing.Optional[str] = OMIT,
786798
request_options: typing.Optional[RequestOptions] = None,
787-
) -> AsyncHttpResponse[GetTriggerResponseData]:
799+
) -> AsyncHttpResponse[Emitter]:
788800
"""
789801
Modify the configuration of a deployed trigger, including active status
790802
@@ -808,7 +820,7 @@ async def update(
808820
809821
Returns
810822
-------
811-
AsyncHttpResponse[GetTriggerResponseData]
823+
AsyncHttpResponse[Emitter]
812824
deployed trigger updated
813825
"""
814826
_response = await self._client_wrapper.httpx_client.request(

0 commit comments

Comments
 (0)