SDK regeneration

Author: fern-api[bot]

README.md

@@ -5,6 +5,21 @@
 
 The Pipedream Python library provides convenient access to the Pipedream APIs from Python.
 
+## Table of Contents
+
+- [Installation](#installation)
+- [Reference](#reference)
+- [Usage](#usage)
+- [Async Client](#async-client)
+- [Exception Handling](#exception-handling)
+- [Pagination](#pagination)
+- [Advanced](#advanced)
+  - [Access Raw Response Data](#access-raw-response-data)
+  - [Retries](#retries)
+  - [Timeouts](#timeouts)
+  - [Custom Client](#custom-client)
+- [Contributing](#contributing)
+
 ## Installation
 
 ```sh

poetry.lock

@@ -3,7 +3,7 @@ name = "pipedream"
 
 [tool.poetry]
 name = "pipedream"
-version = "1.0.11"
+version = "1.0.12"
 description = ""
 readme = "README.md"
 authors = []

pyproject.toml

@@ -2,3 +2,33 @@
 
 # isort: skip_file
 
+import typing
+from importlib import import_module
+
+if typing.TYPE_CHECKING:
+    from .types import ActionsListRequestRegistry
+_dynamic_imports: typing.Dict[str, str] = {"ActionsListRequestRegistry": ".types"}
+
+
+def __getattr__(attr_name: str) -> typing.Any:
+    module_name = _dynamic_imports.get(attr_name)
+    if module_name is None:
+        raise AttributeError(f"No {attr_name} found in _dynamic_imports for module name -> {__name__}")
+    try:
+        module = import_module(module_name, __package__)
+        if module_name == f".{attr_name}":
+            return module
+        else:
+            return getattr(module, attr_name)
+    except ImportError as e:
+        raise ImportError(f"Failed to import {attr_name} from {module_name}: {e}") from e
+    except AttributeError as e:
+        raise AttributeError(f"Failed to get {attr_name} from {module_name}: {e}") from e
+
+
+def __dir__():
+    lazy_attrs = list(_dynamic_imports.keys())
+    return sorted(lazy_attrs)
+
+
+__all__ = ["ActionsListRequestRegistry"]

src/pipedream/actions/__init__.py

@@ -12,6 +12,7 @@
 from ..types.run_action_opts_stash_id import RunActionOptsStashId
 from ..types.run_action_response import RunActionResponse
 from .raw_client import AsyncRawActionsClient, RawActionsClient
+from .types.actions_list_request_registry import ActionsListRequestRegistry
 
 # this is used as the default value for optional parameters
 OMIT = typing.cast(typing.Any, ...)
@@ -40,6 +41,7 @@ def list(
         limit: typing.Optional[int] = None,
         q: typing.Optional[str] = None,
         app: typing.Optional[str] = None,
+        registry: typing.Optional[ActionsListRequestRegistry] = None,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> SyncPager[Component]:
         """
@@ -62,6 +64,9 @@ def list(
         app : typing.Optional[str]
             The ID or name slug of the app to filter the actions
 
+        registry : typing.Optional[ActionsListRequestRegistry]
+            The registry to retrieve actions from. Defaults to 'all' ('public', 'private', or 'all')
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -86,6 +91,7 @@ def list(
             limit=1,
             q="q",
             app="app",
+            registry="public",
         )
         for item in response:
             yield item
@@ -94,7 +100,7 @@ def list(
             yield page
         """
         return self._raw_client.list(
-            after=after, before=before, limit=limit, q=q, app=app, request_options=request_options
+            after=after, before=before, limit=limit, q=q, app=app, registry=registry, request_options=request_options
         )
 
     def retrieve(
@@ -386,6 +392,7 @@ async def list(
         limit: typing.Optional[int] = None,
         q: typing.Optional[str] = None,
         app: typing.Optional[str] = None,
+        registry: typing.Optional[ActionsListRequestRegistry] = None,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> AsyncPager[Component]:
         """
@@ -408,6 +415,9 @@ async def list(
         app : typing.Optional[str]
             The ID or name slug of the app to filter the actions
 
+        registry : typing.Optional[ActionsListRequestRegistry]
+            The registry to retrieve actions from. Defaults to 'all' ('public', 'private', or 'all')
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -437,6 +447,7 @@ async def main() -> None:
                 limit=1,
                 q="q",
                 app="app",
+                registry="public",
             )
             async for item in response:
                 yield item
@@ -449,7 +460,7 @@ async def main() -> None:
         asyncio.run(main())
         """
         return await self._raw_client.list(
-            after=after, before=before, limit=limit, q=q, app=app, request_options=request_options
+            after=after, before=before, limit=limit, q=q, app=app, registry=registry, request_options=request_options
         )
 
     async def retrieve(

src/pipedream/actions/client.py

@@ -20,6 +20,7 @@
 from ..types.reload_props_response import ReloadPropsResponse
 from ..types.run_action_opts_stash_id import RunActionOptsStashId
 from ..types.run_action_response import RunActionResponse
+from .types.actions_list_request_registry import ActionsListRequestRegistry
 
 # this is used as the default value for optional parameters
 OMIT = typing.cast(typing.Any, ...)
@@ -37,6 +38,7 @@ def list(
         limit: typing.Optional[int] = None,
         q: typing.Optional[str] = None,
         app: typing.Optional[str] = None,
+        registry: typing.Optional[ActionsListRequestRegistry] = None,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> SyncPager[Component]:
         """
@@ -59,6 +61,9 @@ def list(
         app : typing.Optional[str]
             The ID or name slug of the app to filter the actions
 
+        registry : typing.Optional[ActionsListRequestRegistry]
+            The registry to retrieve actions from. Defaults to 'all' ('public', 'private', or 'all')
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -76,6 +81,7 @@ def list(
                 "limit": limit,
                 "q": q,
                 "app": app,
+                "registry": registry,
             },
             request_options=request_options,
         )
@@ -100,6 +106,7 @@ def list(
                         limit=limit,
                         q=q,
                         app=app,
+                        registry=registry,
                         request_options=request_options,
                     )
                 return SyncPager(
@@ -474,6 +481,7 @@ async def list(
         limit: typing.Optional[int] = None,
         q: typing.Optional[str] = None,
         app: typing.Optional[str] = None,
+        registry: typing.Optional[ActionsListRequestRegistry] = None,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> AsyncPager[Component]:
         """
@@ -496,6 +504,9 @@ async def list(
         app : typing.Optional[str]
             The ID or name slug of the app to filter the actions
 
+        registry : typing.Optional[ActionsListRequestRegistry]
+            The registry to retrieve actions from. Defaults to 'all' ('public', 'private', or 'all')
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -513,6 +524,7 @@ async def list(
                 "limit": limit,
                 "q": q,
                 "app": app,
+                "registry": registry,
             },
             request_options=request_options,
         )
@@ -539,6 +551,7 @@ async def _get_next():
                             limit=limit,
                             q=q,
                             app=app,
+                            registry=registry,
                             request_options=request_options,
                         )
 

src/pipedream/actions/raw_client.py

@@ -0,0 +1,34 @@
+# This file was auto-generated by Fern from our API Definition.
+
+# isort: skip_file
+
+import typing
+from importlib import import_module
+
+if typing.TYPE_CHECKING:
+    from .actions_list_request_registry import ActionsListRequestRegistry
+_dynamic_imports: typing.Dict[str, str] = {"ActionsListRequestRegistry": ".actions_list_request_registry"}
+
+
+def __getattr__(attr_name: str) -> typing.Any:
+    module_name = _dynamic_imports.get(attr_name)
+    if module_name is None:
+        raise AttributeError(f"No {attr_name} found in _dynamic_imports for module name -> {__name__}")
+    try:
+        module = import_module(module_name, __package__)
+        if module_name == f".{attr_name}":
+            return module
+        else:
+            return getattr(module, attr_name)
+    except ImportError as e:
+        raise ImportError(f"Failed to import {attr_name} from {module_name}: {e}") from e
+    except AttributeError as e:
+        raise AttributeError(f"Failed to get {attr_name} from {module_name}: {e}") from e
+
+
+def __dir__():
+    lazy_attrs = list(_dynamic_imports.keys())
+    return sorted(lazy_attrs)
+
+
+__all__ = ["ActionsListRequestRegistry"]

src/pipedream/actions/types/__init__.py

@@ -0,0 +1,5 @@
+# This file was auto-generated by Fern from our API Definition.
+
+import typing
+
+ActionsListRequestRegistry = typing.Union[typing.Literal["public", "private", "all"], typing.Any]

src/pipedream/actions/types/actions_list_request_registry.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

src/pipedream/client.py

@@ -2,3 +2,33 @@
 
 # isort: skip_file
 
+import typing
+from importlib import import_module
+
+if typing.TYPE_CHECKING:
+    from .types import ComponentsListRequestRegistry
+_dynamic_imports: typing.Dict[str, str] = {"ComponentsListRequestRegistry": ".types"}
+
+
+def __getattr__(attr_name: str) -> typing.Any:
+    module_name = _dynamic_imports.get(attr_name)
+    if module_name is None:
+        raise AttributeError(f"No {attr_name} found in _dynamic_imports for module name -> {__name__}")
+    try:
+        module = import_module(module_name, __package__)
+        if module_name == f".{attr_name}":
+            return module
+        else:
+            return getattr(module, attr_name)
+    except ImportError as e:
+        raise ImportError(f"Failed to import {attr_name} from {module_name}: {e}") from e
+    except AttributeError as e:
+        raise AttributeError(f"Failed to get {attr_name} from {module_name}: {e}") from e
+
+
+def __dir__():
+    lazy_attrs = list(_dynamic_imports.keys())
+    return sorted(lazy_attrs)
+
+
+__all__ = ["ComponentsListRequestRegistry"]