PipedreamHQ · fern-api · Oct 24, 2025
diff --git a/pyproject.toml b/pyproject.toml
@@ -3,7 +3,7 @@ name = "pipedream"
 
 [tool.poetry]
 name = "pipedream"
-version = "1.0.10"
+version = "1.0.11"
 description = ""
 readme = "README.md"
 authors = []

diff --git a/src/pipedream/client.py b/src/pipedream/client.py
@@ -6,7 +6,7 @@
 import typing
 
 import httpx
-from .types.project_environment import ProjectEnvironment
+from ._.types.project_environment import ProjectEnvironment
 from .core.api_error import ApiError
 from .core.client_wrapper import AsyncClientWrapper, SyncClientWrapper
 from .core.oauth_token_provider import OAuthTokenProvider

diff --git a/src/pipedream/core/client_wrapper.py b/src/pipedream/core/client_wrapper.py
@@ -3,7 +3,7 @@
 import typing
 
 import httpx
-from ..types.project_environment import ProjectEnvironment
+from .._.types.project_environment import ProjectEnvironment
 from .http_client import AsyncHttpClient, HttpClient
 
 
@@ -27,10 +27,10 @@ def __init__(
 
     def get_headers(self) -> typing.Dict[str, str]:
         headers: typing.Dict[str, str] = {
-            "User-Agent": "pipedream/1.0.10",
+            "User-Agent": "pipedream/1.0.11",
             "X-Fern-Language": "Python",
             "X-Fern-SDK-Name": "pipedream",
-            "X-Fern-SDK-Version": "1.0.10",
+            "X-Fern-SDK-Version": "1.0.11",
             **(self.get_custom_headers() or {}),
         }
         if self._project_environment is not None:

diff --git a/src/pipedream/deployed_triggers/client.py b/src/pipedream/deployed_triggers/client.py
@@ -6,9 +6,9 @@
 from ..core.pagination import AsyncPager, SyncPager
 from ..core.request_options import RequestOptions
 from ..types.configured_props import ConfiguredProps
-from ..types.deployed_component import DeployedComponent
 from ..types.emitted_event import EmittedEvent
-from ..types.get_trigger_response_data import GetTriggerResponseData
+from ..types.emitter import Emitter
+from ..types.emitter_type import EmitterType
 from ..types.get_trigger_webhooks_response import GetTriggerWebhooksResponse
 from ..types.get_trigger_workflows_response import GetTriggerWorkflowsResponse
 from .raw_client import AsyncRawDeployedTriggersClient, RawDeployedTriggersClient
@@ -39,8 +39,9 @@ def list(
         after: typing.Optional[str] = None,
         before: typing.Optional[str] = None,
         limit: typing.Optional[int] = None,
+        emitter_type: typing.Optional[EmitterType] = None,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> SyncPager[DeployedComponent]:
+    ) -> SyncPager[Emitter]:
         """
         Retrieve all deployed triggers for a specific external user
 
@@ -58,12 +59,15 @@ def list(
         limit : typing.Optional[int]
             The maximum number of results to return
 
+        emitter_type : typing.Optional[EmitterType]
+            Filter deployed triggers by emitter type (defaults to 'source' if not provided)
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
         Returns
         -------
-        SyncPager[DeployedComponent]
+        SyncPager[Emitter]
             deployed triggers listed
 
         Examples
@@ -81,6 +85,7 @@ def list(
             before="before",
             limit=1,
             external_user_id="external_user_id",
+            emitter_type="email",
         )
         for item in response:
             yield item
@@ -89,12 +94,17 @@ def list(
             yield page
         """
         return self._raw_client.list(
-            external_user_id=external_user_id, after=after, before=before, limit=limit, request_options=request_options
+            external_user_id=external_user_id,
+            after=after,
+            before=before,
+            limit=limit,
+            emitter_type=emitter_type,
+            request_options=request_options,
         )
 
     def retrieve(
         self, trigger_id: str, *, external_user_id: str, request_options: typing.Optional[RequestOptions] = None
-    ) -> GetTriggerResponseData:
+    ) -> Emitter:
         """
         Get details of a specific deployed trigger by its ID
 
@@ -110,7 +120,7 @@ def retrieve(
 
         Returns
         -------
-        GetTriggerResponseData
+        Emitter
             deployed trigger retrieved
 
         Examples
@@ -142,7 +152,7 @@ def update(
         configured_props: typing.Optional[ConfiguredProps] = OMIT,
         name: typing.Optional[str] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> GetTriggerResponseData:
+    ) -> Emitter:
         """
         Modify the configuration of a deployed trigger, including active status
 
@@ -166,7 +176,7 @@ def update(
 
         Returns
         -------
-        GetTriggerResponseData
+        Emitter
             deployed trigger updated
 
         Examples
@@ -501,8 +511,9 @@ async def list(
         after: typing.Optional[str] = None,
         before: typing.Optional[str] = None,
         limit: typing.Optional[int] = None,
+        emitter_type: typing.Optional[EmitterType] = None,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> AsyncPager[DeployedComponent]:
+    ) -> AsyncPager[Emitter]:
         """
         Retrieve all deployed triggers for a specific external user
 
@@ -520,12 +531,15 @@ async def list(
         limit : typing.Optional[int]
             The maximum number of results to return
 
+        emitter_type : typing.Optional[EmitterType]
+            Filter deployed triggers by emitter type (defaults to 'source' if not provided)
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
         Returns
         -------
-        AsyncPager[DeployedComponent]
+        AsyncPager[Emitter]
             deployed triggers listed
 
         Examples
@@ -548,6 +562,7 @@ async def main() -> None:
                 before="before",
                 limit=1,
                 external_user_id="external_user_id",
+                emitter_type="email",
             )
             async for item in response:
                 yield item
@@ -560,12 +575,17 @@ async def main() -> None:
         asyncio.run(main())
         """
         return await self._raw_client.list(
-            external_user_id=external_user_id, after=after, before=before, limit=limit, request_options=request_options
+            external_user_id=external_user_id,
+            after=after,
+            before=before,
+            limit=limit,
+            emitter_type=emitter_type,
+            request_options=request_options,
         )
 
     async def retrieve(
         self, trigger_id: str, *, external_user_id: str, request_options: typing.Optional[RequestOptions] = None
-    ) -> GetTriggerResponseData:
+    ) -> Emitter:
         """
         Get details of a specific deployed trigger by its ID
 
@@ -581,7 +601,7 @@ async def retrieve(
 
         Returns
         -------
-        GetTriggerResponseData
+        Emitter
             deployed trigger retrieved
 
         Examples
@@ -621,7 +641,7 @@ async def update(
         configured_props: typing.Optional[ConfiguredProps] = OMIT,
         name: typing.Optional[str] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> GetTriggerResponseData:
+    ) -> Emitter:
         """
         Modify the configuration of a deployed trigger, including active status
 
@@ -645,7 +665,7 @@ async def update(
 
         Returns
         -------
-        GetTriggerResponseData
+        Emitter
             deployed trigger updated
 
         Examples

diff --git a/src/pipedream/deployed_triggers/raw_client.py b/src/pipedream/deployed_triggers/raw_client.py
@@ -13,11 +13,11 @@
 from ..core.serialization import convert_and_respect_annotation_metadata
 from ..errors.too_many_requests_error import TooManyRequestsError
 from ..types.configured_props import ConfiguredProps
-from ..types.deployed_component import DeployedComponent
 from ..types.emitted_event import EmittedEvent
+from ..types.emitter import Emitter
+from ..types.emitter_type import EmitterType
 from ..types.get_trigger_events_response import GetTriggerEventsResponse
 from ..types.get_trigger_response import GetTriggerResponse
-from ..types.get_trigger_response_data import GetTriggerResponseData
 from ..types.get_trigger_webhooks_response import GetTriggerWebhooksResponse
 from ..types.get_trigger_workflows_response import GetTriggerWorkflowsResponse
 from ..types.get_triggers_response import GetTriggersResponse
@@ -37,8 +37,9 @@ def list(
         after: typing.Optional[str] = None,
         before: typing.Optional[str] = None,
         limit: typing.Optional[int] = None,
+        emitter_type: typing.Optional[EmitterType] = None,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> SyncPager[DeployedComponent]:
+    ) -> SyncPager[Emitter]:
         """
         Retrieve all deployed triggers for a specific external user
 
@@ -56,12 +57,15 @@ def list(
         limit : typing.Optional[int]
             The maximum number of results to return
 
+        emitter_type : typing.Optional[EmitterType]
+            Filter deployed triggers by emitter type (defaults to 'source' if not provided)
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
         Returns
         -------
-        SyncPager[DeployedComponent]
+        SyncPager[Emitter]
             deployed triggers listed
         """
         _response = self._client_wrapper.httpx_client.request(
@@ -72,6 +76,7 @@ def list(
                 "before": before,
                 "limit": limit,
                 "external_user_id": external_user_id,
+                "emitter_type": emitter_type,
             },
             request_options=request_options,
         )
@@ -95,6 +100,7 @@ def list(
                         after=_parsed_next,
                         before=before,
                         limit=limit,
+                        emitter_type=emitter_type,
                         request_options=request_options,
                     )
                 return SyncPager(
@@ -118,7 +124,7 @@ def list(
 
     def retrieve(
         self, trigger_id: str, *, external_user_id: str, request_options: typing.Optional[RequestOptions] = None
-    ) -> HttpResponse[GetTriggerResponseData]:
+    ) -> HttpResponse[Emitter]:
         """
         Get details of a specific deployed trigger by its ID
 
@@ -134,7 +140,7 @@ def retrieve(
 
         Returns
         -------
-        HttpResponse[GetTriggerResponseData]
+        HttpResponse[Emitter]
             deployed trigger retrieved
         """
         _response = self._client_wrapper.httpx_client.request(
@@ -181,7 +187,7 @@ def update(
         configured_props: typing.Optional[ConfiguredProps] = OMIT,
         name: typing.Optional[str] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> HttpResponse[GetTriggerResponseData]:
+    ) -> HttpResponse[Emitter]:
         """
         Modify the configuration of a deployed trigger, including active status
 
@@ -205,7 +211,7 @@ def update(
 
         Returns
         -------
-        HttpResponse[GetTriggerResponseData]
+        HttpResponse[Emitter]
             deployed trigger updated
         """
         _response = self._client_wrapper.httpx_client.request(
@@ -637,8 +643,9 @@ async def list(
         after: typing.Optional[str] = None,
         before: typing.Optional[str] = None,
         limit: typing.Optional[int] = None,
+        emitter_type: typing.Optional[EmitterType] = None,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> AsyncPager[DeployedComponent]:
+    ) -> AsyncPager[Emitter]:
         """
         Retrieve all deployed triggers for a specific external user
 
@@ -656,12 +663,15 @@ async def list(
         limit : typing.Optional[int]
             The maximum number of results to return
 
+        emitter_type : typing.Optional[EmitterType]
+            Filter deployed triggers by emitter type (defaults to 'source' if not provided)
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
         Returns
         -------
-        AsyncPager[DeployedComponent]
+        AsyncPager[Emitter]
             deployed triggers listed
         """
         _response = await self._client_wrapper.httpx_client.request(
@@ -672,6 +682,7 @@ async def list(
                 "before": before,
                 "limit": limit,
                 "external_user_id": external_user_id,
+                "emitter_type": emitter_type,
             },
             request_options=request_options,
         )
@@ -697,6 +708,7 @@ async def _get_next():
                             after=_parsed_next,
                             before=before,
                             limit=limit,
+                            emitter_type=emitter_type,
                             request_options=request_options,
                         )
 
@@ -721,7 +733,7 @@ async def _get_next():
 
     async def retrieve(
         self, trigger_id: str, *, external_user_id: str, request_options: typing.Optional[RequestOptions] = None
-    ) -> AsyncHttpResponse[GetTriggerResponseData]:
+    ) -> AsyncHttpResponse[Emitter]:
         """
         Get details of a specific deployed trigger by its ID
 
@@ -737,7 +749,7 @@ async def retrieve(
 
         Returns
         -------
-        AsyncHttpResponse[GetTriggerResponseData]
+        AsyncHttpResponse[Emitter]
             deployed trigger retrieved
         """
         _response = await self._client_wrapper.httpx_client.request(
@@ -784,7 +796,7 @@ async def update(
         configured_props: typing.Optional[ConfiguredProps] = OMIT,
         name: typing.Optional[str] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> AsyncHttpResponse[GetTriggerResponseData]:
+    ) -> AsyncHttpResponse[Emitter]:
         """
         Modify the configuration of a deployed trigger, including active status
 
@@ -808,7 +820,7 @@ async def update(
 
         Returns
         -------
-        AsyncHttpResponse[GetTriggerResponseData]
+        AsyncHttpResponse[Emitter]
             deployed trigger updated
         """
         _response = await self._client_wrapper.httpx_client.request(