Skip to content

Commit 578f9f6

Browse files
fern-api[bot]fern-api[bot]
authored
SDK regeneration
1 parent 4689a96 commit 578f9f6

32 files changed

+1586
-53
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.12"
6+
version = "1.0.13"
77
description = ""
88
readme = "README.md"
99
authors = []

‎src/pipedream/actions/__init__.py‎

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,3 +2,33 @@
22

33
# isort: skip_file
44

5+
import typing
6+
from importlib import import_module
7+
8+
if typing.TYPE_CHECKING:
9+
from .types import ListActionsRequestRegistry
10+
_dynamic_imports: typing.Dict[str, str] = {"ListActionsRequestRegistry": ".types"}
11+
12+
13+
def __getattr__(attr_name: str) -> typing.Any:
14+
module_name = _dynamic_imports.get(attr_name)
15+
if module_name is None:
16+
raise AttributeError(f"No {attr_name} found in _dynamic_imports for module name -> {__name__}")
17+
try:
18+
module = import_module(module_name, __package__)
19+
if module_name == f".{attr_name}":
20+
return module
21+
else:
22+
return getattr(module, attr_name)
23+
except ImportError as e:
24+
raise ImportError(f"Failed to import {attr_name} from {module_name}: {e}") from e
25+
except AttributeError as e:
26+
raise AttributeError(f"Failed to get {attr_name} from {module_name}: {e}") from e
27+
28+
29+
def __dir__():
30+
lazy_attrs = list(_dynamic_imports.keys())
31+
return sorted(lazy_attrs)
32+
33+
34+
__all__ = ["ListActionsRequestRegistry"]

‎src/pipedream/actions/client.py‎

Lines changed: 13 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
from ..types.run_action_opts_stash_id import RunActionOptsStashId
1313
from ..types.run_action_response import RunActionResponse
1414
from .raw_client import AsyncRawActionsClient, RawActionsClient
15+
from .types.list_actions_request_registry import ListActionsRequestRegistry
1516

1617
# this is used as the default value for optional parameters
1718
OMIT = typing.cast(typing.Any, ...)
@@ -40,6 +41,7 @@ def list(
4041
limit: typing.Optional[int] = None,
4142
q: typing.Optional[str] = None,
4243
app: typing.Optional[str] = None,
44+
registry: typing.Optional[ListActionsRequestRegistry] = None,
4345
request_options: typing.Optional[RequestOptions] = None,
4446
) -> SyncPager[Component]:
4547
"""
@@ -62,13 +64,16 @@ def list(
6264
app : typing.Optional[str]
6365
The ID or name slug of the app to filter the actions
6466
67+
registry : typing.Optional[ListActionsRequestRegistry]
68+
The registry to retrieve actions from. Defaults to 'all' ('public', 'private', or 'all')
69+
6570
request_options : typing.Optional[RequestOptions]
6671
Request-specific configuration.
6772
6873
Returns
6974
-------
7075
SyncPager[Component]
71-
actions listed
76+
behaves like registry=all
7277
7378
Examples
7479
--------
@@ -88,7 +93,7 @@ def list(
8893
yield page
8994
"""
9095
return self._raw_client.list(
91-
after=after, before=before, limit=limit, q=q, app=app, request_options=request_options
96+
after=after, before=before, limit=limit, q=q, app=app, registry=registry, request_options=request_options
9297
)
9398

9499
def retrieve(
@@ -380,6 +385,7 @@ async def list(
380385
limit: typing.Optional[int] = None,
381386
q: typing.Optional[str] = None,
382387
app: typing.Optional[str] = None,
388+
registry: typing.Optional[ListActionsRequestRegistry] = None,
383389
request_options: typing.Optional[RequestOptions] = None,
384390
) -> AsyncPager[Component]:
385391
"""
@@ -402,13 +408,16 @@ async def list(
402408
app : typing.Optional[str]
403409
The ID or name slug of the app to filter the actions
404410
411+
registry : typing.Optional[ListActionsRequestRegistry]
412+
The registry to retrieve actions from. Defaults to 'all' ('public', 'private', or 'all')
413+
405414
request_options : typing.Optional[RequestOptions]
406415
Request-specific configuration.
407416
408417
Returns
409418
-------
410419
AsyncPager[Component]
411-
actions listed
420+
behaves like registry=all
412421
413422
Examples
414423
--------
@@ -437,7 +446,7 @@ async def main() -> None:
437446
asyncio.run(main())
438447
"""
439448
return await self._raw_client.list(
440-
after=after, before=before, limit=limit, q=q, app=app, request_options=request_options
449+
after=after, before=before, limit=limit, q=q, app=app, registry=registry, request_options=request_options
441450
)
442451

443452
async def retrieve(

‎src/pipedream/actions/raw_client.py‎

Lines changed: 38 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
from ..core.pydantic_utilities import parse_obj_as
1212
from ..core.request_options import RequestOptions
1313
from ..core.serialization import convert_and_respect_annotation_metadata
14+
from ..errors.bad_request_error import BadRequestError
1415
from ..errors.too_many_requests_error import TooManyRequestsError
1516
from ..types.component import Component
1617
from ..types.configure_prop_response import ConfigurePropResponse
@@ -20,6 +21,7 @@
2021
from ..types.reload_props_response import ReloadPropsResponse
2122
from ..types.run_action_opts_stash_id import RunActionOptsStashId
2223
from ..types.run_action_response import RunActionResponse
24+
from .types.list_actions_request_registry import ListActionsRequestRegistry
2325

2426
# this is used as the default value for optional parameters
2527
OMIT = typing.cast(typing.Any, ...)
@@ -37,6 +39,7 @@ def list(
3739
limit: typing.Optional[int] = None,
3840
q: typing.Optional[str] = None,
3941
app: typing.Optional[str] = None,
42+
registry: typing.Optional[ListActionsRequestRegistry] = None,
4043
request_options: typing.Optional[RequestOptions] = None,
4144
) -> SyncPager[Component]:
4245
"""
@@ -59,13 +62,16 @@ def list(
5962
app : typing.Optional[str]
6063
The ID or name slug of the app to filter the actions
6164
65+
registry : typing.Optional[ListActionsRequestRegistry]
66+
The registry to retrieve actions from. Defaults to 'all' ('public', 'private', or 'all')
67+
6268
request_options : typing.Optional[RequestOptions]
6369
Request-specific configuration.
6470
6571
Returns
6672
-------
6773
SyncPager[Component]
68-
actions listed
74+
behaves like registry=all
6975
"""
7076
_response = self._client_wrapper.httpx_client.request(
7177
f"v1/connect/{jsonable_encoder(self._client_wrapper._project_id)}/actions",
@@ -76,6 +82,7 @@ def list(
7682
"limit": limit,
7783
"q": q,
7884
"app": app,
85+
"registry": registry,
7986
},
8087
request_options=request_options,
8188
)
@@ -100,11 +107,23 @@ def list(
100107
limit=limit,
101108
q=q,
102109
app=app,
110+
registry=registry,
103111
request_options=request_options,
104112
)
105113
return SyncPager(
106114
has_next=_has_next, items=_items, get_next=_get_next, response=BaseHttpResponse(response=_response)
107115
)
116+
if _response.status_code == 400:
117+
raise BadRequestError(
118+
headers=dict(_response.headers),
119+
body=typing.cast(
120+
typing.Optional[typing.Any],
121+
parse_obj_as(
122+
type_=typing.Optional[typing.Any], # type: ignore
123+
object_=_response.json(),
124+
),
125+
),
126+
)
108127
if _response.status_code == 429:
109128
raise TooManyRequestsError(
110129
headers=dict(_response.headers),
@@ -474,6 +493,7 @@ async def list(
474493
limit: typing.Optional[int] = None,
475494
q: typing.Optional[str] = None,
476495
app: typing.Optional[str] = None,
496+
registry: typing.Optional[ListActionsRequestRegistry] = None,
477497
request_options: typing.Optional[RequestOptions] = None,
478498
) -> AsyncPager[Component]:
479499
"""
@@ -496,13 +516,16 @@ async def list(
496516
app : typing.Optional[str]
497517
The ID or name slug of the app to filter the actions
498518
519+
registry : typing.Optional[ListActionsRequestRegistry]
520+
The registry to retrieve actions from. Defaults to 'all' ('public', 'private', or 'all')
521+
499522
request_options : typing.Optional[RequestOptions]
500523
Request-specific configuration.
501524
502525
Returns
503526
-------
504527
AsyncPager[Component]
505-
actions listed
528+
behaves like registry=all
506529
"""
507530
_response = await self._client_wrapper.httpx_client.request(
508531
f"v1/connect/{jsonable_encoder(self._client_wrapper._project_id)}/actions",
@@ -513,6 +536,7 @@ async def list(
513536
"limit": limit,
514537
"q": q,
515538
"app": app,
539+
"registry": registry,
516540
},
517541
request_options=request_options,
518542
)
@@ -539,12 +563,24 @@ async def _get_next():
539563
limit=limit,
540564
q=q,
541565
app=app,
566+
registry=registry,
542567
request_options=request_options,
543568
)
544569

545570
return AsyncPager(
546571
has_next=_has_next, items=_items, get_next=_get_next, response=BaseHttpResponse(response=_response)
547572
)
573+
if _response.status_code == 400:
574+
raise BadRequestError(
575+
headers=dict(_response.headers),
576+
body=typing.cast(
577+
typing.Optional[typing.Any],
578+
parse_obj_as(
579+
type_=typing.Optional[typing.Any], # type: ignore
580+
object_=_response.json(),
581+
),
582+
),
583+
)
548584
if _response.status_code == 429:
549585
raise TooManyRequestsError(
550586
headers=dict(_response.headers),

‎src/pipedream/actions/types/__init__.py‎

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
# This file was auto-generated by Fern from our API Definition.
2+
3+
# isort: skip_file
4+
5+
import typing
6+
from importlib import import_module
7+
8+
if typing.TYPE_CHECKING:
9+
from .list_actions_request_registry import ListActionsRequestRegistry
10+
_dynamic_imports: typing.Dict[str, str] = {"ListActionsRequestRegistry": ".list_actions_request_registry"}
11+
12+
13+
def __getattr__(attr_name: str) -> typing.Any:
14+
module_name = _dynamic_imports.get(attr_name)
15+
if module_name is None:
16+
raise AttributeError(f"No {attr_name} found in _dynamic_imports for module name -> {__name__}")
17+
try:
18+
module = import_module(module_name, __package__)
19+
if module_name == f".{attr_name}":
20+
return module
21+
else:
22+
return getattr(module, attr_name)
23+
except ImportError as e:
24+
raise ImportError(f"Failed to import {attr_name} from {module_name}: {e}") from e
25+
except AttributeError as e:
26+
raise AttributeError(f"Failed to get {attr_name} from {module_name}: {e}") from e
27+
28+
29+
def __dir__():
30+
lazy_attrs = list(_dynamic_imports.keys())
31+
return sorted(lazy_attrs)
32+
33+
34+
__all__ = ["ListActionsRequestRegistry"]

‎src/pipedream/actions/types/list_actions_request_registry.py‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
# This file was auto-generated by Fern from our API Definition.
2+
3+
import typing
4+
5+
ListActionsRequestRegistry = typing.Union[typing.Literal["public", "private", "all"], typing.Any]

‎src/pipedream/apps/__init__.py‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@
66
from importlib import import_module
77

88
if typing.TYPE_CHECKING:
9-
from .types import AppsListRequestSortDirection, AppsListRequestSortKey
10-
_dynamic_imports: typing.Dict[str, str] = {"AppsListRequestSortDirection": ".types", "AppsListRequestSortKey": ".types"}
9+
from .types import ListAppsRequestSortDirection, ListAppsRequestSortKey
10+
_dynamic_imports: typing.Dict[str, str] = {"ListAppsRequestSortDirection": ".types", "ListAppsRequestSortKey": ".types"}
1111

1212

1313
def __getattr__(attr_name: str) -> typing.Any:
@@ -31,4 +31,4 @@ def __dir__():
3131
return sorted(lazy_attrs)
3232

3333

34-
__all__ = ["AppsListRequestSortDirection", "AppsListRequestSortKey"]
34+
__all__ = ["ListAppsRequestSortDirection", "ListAppsRequestSortKey"]

‎src/pipedream/apps/client.py‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,8 @@
88
from ..types.app import App
99
from ..types.get_app_response import GetAppResponse
1010
from .raw_client import AsyncRawAppsClient, RawAppsClient
11-
from .types.apps_list_request_sort_direction import AppsListRequestSortDirection
12-
from .types.apps_list_request_sort_key import AppsListRequestSortKey
11+
from .types.list_apps_request_sort_direction import ListAppsRequestSortDirection
12+
from .types.list_apps_request_sort_key import ListAppsRequestSortKey
1313

1414

1515
class AppsClient:
@@ -34,8 +34,8 @@ def list(
3434
before: typing.Optional[str] = None,
3535
limit: typing.Optional[int] = None,
3636
q: typing.Optional[str] = None,
37-
sort_key: typing.Optional[AppsListRequestSortKey] = None,
38-
sort_direction: typing.Optional[AppsListRequestSortDirection] = None,
37+
sort_key: typing.Optional[ListAppsRequestSortKey] = None,
38+
sort_direction: typing.Optional[ListAppsRequestSortDirection] = None,
3939
category_ids: typing.Optional[typing.Union[str, typing.Sequence[str]]] = None,
4040
request_options: typing.Optional[RequestOptions] = None,
4141
) -> SyncPager[App]:
@@ -56,10 +56,10 @@ def list(
5656
q : typing.Optional[str]
5757
A search query to filter the apps
5858
59-
sort_key : typing.Optional[AppsListRequestSortKey]
59+
sort_key : typing.Optional[ListAppsRequestSortKey]
6060
The key to sort the apps by
6161
62-
sort_direction : typing.Optional[AppsListRequestSortDirection]
62+
sort_direction : typing.Optional[ListAppsRequestSortDirection]
6363
The direction to sort the apps
6464
6565
category_ids : typing.Optional[typing.Union[str, typing.Sequence[str]]]
@@ -158,8 +158,8 @@ async def list(
158158
before: typing.Optional[str] = None,
159159
limit: typing.Optional[int] = None,
160160
q: typing.Optional[str] = None,
161-
sort_key: typing.Optional[AppsListRequestSortKey] = None,
162-
sort_direction: typing.Optional[AppsListRequestSortDirection] = None,
161+
sort_key: typing.Optional[ListAppsRequestSortKey] = None,
162+
sort_direction: typing.Optional[ListAppsRequestSortDirection] = None,
163163
category_ids: typing.Optional[typing.Union[str, typing.Sequence[str]]] = None,
164164
request_options: typing.Optional[RequestOptions] = None,
165165
) -> AsyncPager[App]:
@@ -180,10 +180,10 @@ async def list(
180180
q : typing.Optional[str]
181181
A search query to filter the apps
182182
183-
sort_key : typing.Optional[AppsListRequestSortKey]
183+
sort_key : typing.Optional[ListAppsRequestSortKey]
184184
The key to sort the apps by
185185
186-
sort_direction : typing.Optional[AppsListRequestSortDirection]
186+
sort_direction : typing.Optional[ListAppsRequestSortDirection]
187187
The direction to sort the apps
188188
189189
category_ids : typing.Optional[typing.Union[str, typing.Sequence[str]]]

0 commit comments

Comments
 (0)