Skip to content

Commit 535a99a

Browse files
committed
SDK regeneration
1 parent 4166610 commit 535a99a

File tree

68 files changed

+1084
-547
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

68 files changed

+1084
-547
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,7 @@ from pipedream import Pipedream
175175
client = Pipedream(
176176
...,
177177
httpx_client=httpx.Client(
178-
proxies="http://my.test.proxy.example.com",
178+
proxy="http://my.test.proxy.example.com",
179179
transport=httpx.HTTPTransport(local_address="0.0.0.0"),
180180
),
181181
)

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

src/pipedream/accounts/raw_client.py

Lines changed: 111 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
from ..core.pagination import AsyncPager, BaseHttpResponse, SyncPager
1111
from ..core.pydantic_utilities import parse_obj_as
1212
from ..core.request_options import RequestOptions
13+
from ..errors.too_many_requests_error import TooManyRequestsError
1314
from ..types.account import Account
1415
from ..types.list_accounts_response import ListAccountsResponse
1516

@@ -108,6 +109,17 @@ def list(
108109
return SyncPager(
109110
has_next=_has_next, items=_items, get_next=_get_next, response=BaseHttpResponse(response=_response)
110111
)
112+
if _response.status_code == 429:
113+
raise TooManyRequestsError(
114+
headers=dict(_response.headers),
115+
body=typing.cast(
116+
typing.Optional[typing.Any],
117+
parse_obj_as(
118+
type_=typing.Optional[typing.Any], # type: ignore
119+
object_=_response.json(),
120+
),
121+
),
122+
)
111123
_response_json = _response.json()
112124
except JSONDecodeError:
113125
raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text)
@@ -188,6 +200,17 @@ def create(
188200
),
189201
)
190202
return HttpResponse(response=_response, data=_data)
203+
if _response.status_code == 429:
204+
raise TooManyRequestsError(
205+
headers=dict(_response.headers),
206+
body=typing.cast(
207+
typing.Optional[typing.Any],
208+
parse_obj_as(
209+
type_=typing.Optional[typing.Any], # type: ignore
210+
object_=_response.json(),
211+
),
212+
),
213+
)
191214
_response_json = _response.json()
192215
except JSONDecodeError:
193216
raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text)
@@ -236,6 +259,17 @@ def retrieve(
236259
),
237260
)
238261
return HttpResponse(response=_response, data=_data)
262+
if _response.status_code == 429:
263+
raise TooManyRequestsError(
264+
headers=dict(_response.headers),
265+
body=typing.cast(
266+
typing.Optional[typing.Any],
267+
parse_obj_as(
268+
type_=typing.Optional[typing.Any], # type: ignore
269+
object_=_response.json(),
270+
),
271+
),
272+
)
239273
_response_json = _response.json()
240274
except JSONDecodeError:
241275
raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text)
@@ -264,6 +298,17 @@ def delete(self, account_id: str, *, request_options: typing.Optional[RequestOpt
264298
try:
265299
if 200 <= _response.status_code < 300:
266300
return HttpResponse(response=_response, data=None)
301+
if _response.status_code == 429:
302+
raise TooManyRequestsError(
303+
headers=dict(_response.headers),
304+
body=typing.cast(
305+
typing.Optional[typing.Any],
306+
parse_obj_as(
307+
type_=typing.Optional[typing.Any], # type: ignore
308+
object_=_response.json(),
309+
),
310+
),
311+
)
267312
_response_json = _response.json()
268313
except JSONDecodeError:
269314
raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text)
@@ -294,6 +339,17 @@ def delete_by_app(
294339
try:
295340
if 200 <= _response.status_code < 300:
296341
return HttpResponse(response=_response, data=None)
342+
if _response.status_code == 429:
343+
raise TooManyRequestsError(
344+
headers=dict(_response.headers),
345+
body=typing.cast(
346+
typing.Optional[typing.Any],
347+
parse_obj_as(
348+
type_=typing.Optional[typing.Any], # type: ignore
349+
object_=_response.json(),
350+
),
351+
),
352+
)
297353
_response_json = _response.json()
298354
except JSONDecodeError:
299355
raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text)
@@ -394,6 +450,17 @@ async def _get_next():
394450
return AsyncPager(
395451
has_next=_has_next, items=_items, get_next=_get_next, response=BaseHttpResponse(response=_response)
396452
)
453+
if _response.status_code == 429:
454+
raise TooManyRequestsError(
455+
headers=dict(_response.headers),
456+
body=typing.cast(
457+
typing.Optional[typing.Any],
458+
parse_obj_as(
459+
type_=typing.Optional[typing.Any], # type: ignore
460+
object_=_response.json(),
461+
),
462+
),
463+
)
397464
_response_json = _response.json()
398465
except JSONDecodeError:
399466
raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text)
@@ -474,6 +541,17 @@ async def create(
474541
),
475542
)
476543
return AsyncHttpResponse(response=_response, data=_data)
544+
if _response.status_code == 429:
545+
raise TooManyRequestsError(
546+
headers=dict(_response.headers),
547+
body=typing.cast(
548+
typing.Optional[typing.Any],
549+
parse_obj_as(
550+
type_=typing.Optional[typing.Any], # type: ignore
551+
object_=_response.json(),
552+
),
553+
),
554+
)
477555
_response_json = _response.json()
478556
except JSONDecodeError:
479557
raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text)
@@ -522,6 +600,17 @@ async def retrieve(
522600
),
523601
)
524602
return AsyncHttpResponse(response=_response, data=_data)
603+
if _response.status_code == 429:
604+
raise TooManyRequestsError(
605+
headers=dict(_response.headers),
606+
body=typing.cast(
607+
typing.Optional[typing.Any],
608+
parse_obj_as(
609+
type_=typing.Optional[typing.Any], # type: ignore
610+
object_=_response.json(),
611+
),
612+
),
613+
)
525614
_response_json = _response.json()
526615
except JSONDecodeError:
527616
raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text)
@@ -552,6 +641,17 @@ async def delete(
552641
try:
553642
if 200 <= _response.status_code < 300:
554643
return AsyncHttpResponse(response=_response, data=None)
644+
if _response.status_code == 429:
645+
raise TooManyRequestsError(
646+
headers=dict(_response.headers),
647+
body=typing.cast(
648+
typing.Optional[typing.Any],
649+
parse_obj_as(
650+
type_=typing.Optional[typing.Any], # type: ignore
651+
object_=_response.json(),
652+
),
653+
),
654+
)
555655
_response_json = _response.json()
556656
except JSONDecodeError:
557657
raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text)
@@ -582,6 +682,17 @@ async def delete_by_app(
582682
try:
583683
if 200 <= _response.status_code < 300:
584684
return AsyncHttpResponse(response=_response, data=None)
685+
if _response.status_code == 429:
686+
raise TooManyRequestsError(
687+
headers=dict(_response.headers),
688+
body=typing.cast(
689+
typing.Optional[typing.Any],
690+
parse_obj_as(
691+
type_=typing.Optional[typing.Any], # type: ignore
692+
object_=_response.json(),
693+
),
694+
),
695+
)
585696
_response_json = _response.json()
586697
except JSONDecodeError:
587698
raise ApiError(status_code=_response.status_code, headers=dict(_response.headers), body=_response.text)

src/pipedream/actions/client.py

Lines changed: 18 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
from ..core.request_options import RequestOptions
88
from ..types.component import Component
99
from ..types.configure_prop_response import ConfigurePropResponse
10-
from ..types.configured_props import ConfiguredProps
1110
from ..types.reload_props_response import ReloadPropsResponse
1211
from ..types.run_action_opts_stash_id import RunActionOptsStashId
1312
from ..types.run_action_response import RunActionResponse
@@ -132,7 +131,7 @@ def configure_prop(
132131
external_user_id: str,
133132
prop_name: str,
134133
blocking: typing.Optional[bool] = OMIT,
135-
configured_props: typing.Optional[ConfiguredProps] = OMIT,
134+
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
136135
dynamic_props_id: typing.Optional[str] = OMIT,
137136
page: typing.Optional[float] = OMIT,
138137
prev_context: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
@@ -156,7 +155,8 @@ def configure_prop(
156155
blocking : typing.Optional[bool]
157156
Whether this operation should block until completion
158157
159-
configured_props : typing.Optional[ConfiguredProps]
158+
configured_props : typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]]
159+
The configured properties for the component
160160
161161
dynamic_props_id : typing.Optional[str]
162162
The ID for dynamic props
@@ -214,7 +214,7 @@ def reload_props(
214214
id: str,
215215
external_user_id: str,
216216
blocking: typing.Optional[bool] = OMIT,
217-
configured_props: typing.Optional[ConfiguredProps] = OMIT,
217+
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
218218
dynamic_props_id: typing.Optional[str] = OMIT,
219219
request_options: typing.Optional[RequestOptions] = None,
220220
) -> ReloadPropsResponse:
@@ -232,7 +232,8 @@ def reload_props(
232232
blocking : typing.Optional[bool]
233233
Whether this operation should block until completion
234234
235-
configured_props : typing.Optional[ConfiguredProps]
235+
configured_props : typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]]
236+
The configured properties for the component
236237
237238
dynamic_props_id : typing.Optional[str]
238239
The ID for dynamic props
@@ -275,7 +276,7 @@ def run(
275276
*,
276277
id: str,
277278
external_user_id: str,
278-
configured_props: typing.Optional[ConfiguredProps] = OMIT,
279+
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
279280
dynamic_props_id: typing.Optional[str] = OMIT,
280281
stash_id: typing.Optional[RunActionOptsStashId] = OMIT,
281282
request_options: typing.Optional[RequestOptions] = None,
@@ -291,7 +292,8 @@ def run(
291292
external_user_id : str
292293
The external user ID
293294
294-
configured_props : typing.Optional[ConfiguredProps]
295+
configured_props : typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]]
296+
The configured properties for the action
295297
296298
dynamic_props_id : typing.Optional[str]
297299
The ID for dynamic props
@@ -466,7 +468,7 @@ async def configure_prop(
466468
external_user_id: str,
467469
prop_name: str,
468470
blocking: typing.Optional[bool] = OMIT,
469-
configured_props: typing.Optional[ConfiguredProps] = OMIT,
471+
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
470472
dynamic_props_id: typing.Optional[str] = OMIT,
471473
page: typing.Optional[float] = OMIT,
472474
prev_context: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
@@ -490,7 +492,8 @@ async def configure_prop(
490492
blocking : typing.Optional[bool]
491493
Whether this operation should block until completion
492494
493-
configured_props : typing.Optional[ConfiguredProps]
495+
configured_props : typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]]
496+
The configured properties for the component
494497
495498
dynamic_props_id : typing.Optional[str]
496499
The ID for dynamic props
@@ -556,7 +559,7 @@ async def reload_props(
556559
id: str,
557560
external_user_id: str,
558561
blocking: typing.Optional[bool] = OMIT,
559-
configured_props: typing.Optional[ConfiguredProps] = OMIT,
562+
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
560563
dynamic_props_id: typing.Optional[str] = OMIT,
561564
request_options: typing.Optional[RequestOptions] = None,
562565
) -> ReloadPropsResponse:
@@ -574,7 +577,8 @@ async def reload_props(
574577
blocking : typing.Optional[bool]
575578
Whether this operation should block until completion
576579
577-
configured_props : typing.Optional[ConfiguredProps]
580+
configured_props : typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]]
581+
The configured properties for the component
578582
579583
dynamic_props_id : typing.Optional[str]
580584
The ID for dynamic props
@@ -625,7 +629,7 @@ async def run(
625629
*,
626630
id: str,
627631
external_user_id: str,
628-
configured_props: typing.Optional[ConfiguredProps] = OMIT,
632+
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
629633
dynamic_props_id: typing.Optional[str] = OMIT,
630634
stash_id: typing.Optional[RunActionOptsStashId] = OMIT,
631635
request_options: typing.Optional[RequestOptions] = None,
@@ -641,7 +645,8 @@ async def run(
641645
external_user_id : str
642646
The external user ID
643647
644-
configured_props : typing.Optional[ConfiguredProps]
648+
configured_props : typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]]
649+
The configured properties for the action
645650
646651
dynamic_props_id : typing.Optional[str]
647652
The ID for dynamic props

0 commit comments

Comments
 (0)