Skip to content

Commit 5875d43

Browse files
Revisit types (#66)
* Remove `x-async-handle` logic * Unnest query params for Connect token validation * Add missing configurable prop types and fields --------- Co-authored-by: fern-api <115122769+fern-api[bot]@users.noreply.github.com> Co-authored-by: Jay Vercellone <[email protected]>
1 parent 497b259 commit 5875d43

29 files changed

+1302
-205
lines changed

src/pipedream/__init__.py

Lines changed: 32 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,16 +12,29 @@
1212
Component,
1313
ComponentStash,
1414
ConfigurableProp,
15+
ConfigurablePropAirtableBaseId,
16+
ConfigurablePropAirtableFieldId,
17+
ConfigurablePropAirtableTableId,
18+
ConfigurablePropAirtableViewId,
1519
ConfigurablePropAlert,
1620
ConfigurablePropAlertType,
1721
ConfigurablePropAny,
1822
ConfigurablePropApp,
23+
ConfigurablePropApphook,
1924
ConfigurablePropBoolean,
25+
ConfigurablePropDb,
26+
ConfigurablePropDiscordChannelArray,
27+
ConfigurablePropDiscordChannel,
2028
ConfigurablePropDiscord,
29+
ConfigurablePropHttp,
30+
ConfigurablePropIntegerArray,
2131
ConfigurablePropInteger,
2232
ConfigurablePropObject,
33+
ConfigurablePropSqlAuth,
34+
ConfigurablePropSql,
2335
ConfigurablePropString,
2436
ConfigurablePropStringArray,
37+
ConfigurablePropTimer,
2538
ConfigurePropOpts,
2639
ConfigurePropResponse,
2740
ConnectToken,
@@ -58,7 +71,8 @@
5871
RunActionOptsStashId,
5972
StashId,
6073
StartConnectOpts,
61-
ValidateTokenParams,
74+
TimerCron,
75+
TimerInterval,
6276
ValidateTokenResponse,
6377
)
6478
from . import (
@@ -94,16 +108,29 @@
94108
"Component",
95109
"ComponentStash",
96110
"ConfigurableProp",
111+
"ConfigurablePropAirtableBaseId",
112+
"ConfigurablePropAirtableFieldId",
113+
"ConfigurablePropAirtableTableId",
114+
"ConfigurablePropAirtableViewId",
97115
"ConfigurablePropAlert",
98116
"ConfigurablePropAlertType",
99117
"ConfigurablePropAny",
100118
"ConfigurablePropApp",
119+
"ConfigurablePropApphook",
101120
"ConfigurablePropBoolean",
121+
"ConfigurablePropDb",
122+
"ConfigurablePropDiscordChannelArray",
123+
"ConfigurablePropDiscordChannel",
102124
"ConfigurablePropDiscord",
125+
"ConfigurablePropHttp",
126+
"ConfigurablePropIntegerArray",
103127
"ConfigurablePropInteger",
104128
"ConfigurablePropObject",
105-
"ConfigurablePropString",
129+
"ConfigurablePropSqlAuth",
130+
"ConfigurablePropSql",
106131
"ConfigurablePropStringArray",
132+
"ConfigurablePropString",
133+
"ConfigurablePropTimer",
107134
"ConfigurePropOpts",
108135
"ConfigurePropResponse",
109136
"ConnectToken",
@@ -134,6 +161,7 @@
134161
"ProjectEnvironment",
135162
"ProjectInfoResponse",
136163
"ProjectInfoResponseApp",
164+
"ProjectInfoResponse",
137165
"PropOption",
138166
"ProxyResponse",
139167
"ReloadPropsOpts",
@@ -142,7 +170,8 @@
142170
"RunActionOptsStashId",
143171
"StashId",
144172
"StartConnectOpts",
145-
"ValidateTokenParams",
173+
"TimerCron",
174+
"TimerInterval",
146175
"ValidateTokenResponse",
147176
"__version__",
148177
"accounts",

src/pipedream/actions/client.py

Lines changed: 12 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -126,11 +126,10 @@ def configure_prop(
126126
id: str,
127127
external_user_id: str,
128128
prop_name: str,
129-
async_handle: typing.Optional[str] = None,
130129
blocking: typing.Optional[bool] = OMIT,
131130
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
132131
dynamic_props_id: typing.Optional[str] = OMIT,
133-
configure_prop_opts_async_handle: typing.Optional[str] = OMIT,
132+
async_handle: typing.Optional[str] = OMIT,
134133
page: typing.Optional[float] = OMIT,
135134
prev_context: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
136135
query: typing.Optional[str] = OMIT,
@@ -148,8 +147,6 @@ def configure_prop(
148147
prop_name : str
149148
The name of the prop to configure
150149
151-
async_handle : typing.Optional[str]
152-
153150
blocking : typing.Optional[bool]
154151
Whether this operation should block until completion
155152
@@ -159,7 +156,7 @@ def configure_prop(
159156
dynamic_props_id : typing.Optional[str]
160157
The ID for dynamic props
161158
162-
configure_prop_opts_async_handle : typing.Optional[str]
159+
async_handle : typing.Optional[str]
163160
Handle for async operations
164161
165162
page : typing.Optional[float]
@@ -199,11 +196,10 @@ def configure_prop(
199196
id=id,
200197
external_user_id=external_user_id,
201198
prop_name=prop_name,
202-
async_handle=async_handle,
203199
blocking=blocking,
204200
configured_props=configured_props,
205201
dynamic_props_id=dynamic_props_id,
206-
configure_prop_opts_async_handle=configure_prop_opts_async_handle,
202+
async_handle=async_handle,
207203
page=page,
208204
prev_context=prev_context,
209205
query=query,
@@ -216,11 +212,10 @@ def reload_props(
216212
*,
217213
id: str,
218214
external_user_id: str,
219-
async_handle: typing.Optional[str] = None,
220215
blocking: typing.Optional[bool] = OMIT,
221216
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
222217
dynamic_props_id: typing.Optional[str] = OMIT,
223-
reload_props_opts_async_handle: typing.Optional[str] = OMIT,
218+
async_handle: typing.Optional[str] = OMIT,
224219
request_options: typing.Optional[RequestOptions] = None,
225220
) -> ReloadPropsResponse:
226221
"""
@@ -232,8 +227,6 @@ def reload_props(
232227
external_user_id : str
233228
The external user ID
234229
235-
async_handle : typing.Optional[str]
236-
237230
blocking : typing.Optional[bool]
238231
Whether this operation should block until completion
239232
@@ -243,7 +236,7 @@ def reload_props(
243236
dynamic_props_id : typing.Optional[str]
244237
The ID for dynamic props
245238
246-
reload_props_opts_async_handle : typing.Optional[str]
239+
async_handle : typing.Optional[str]
247240
Handle for async operations
248241
249242
request_options : typing.Optional[RequestOptions]
@@ -272,11 +265,10 @@ def reload_props(
272265
_response = self._raw_client.reload_props(
273266
id=id,
274267
external_user_id=external_user_id,
275-
async_handle=async_handle,
276268
blocking=blocking,
277269
configured_props=configured_props,
278270
dynamic_props_id=dynamic_props_id,
279-
reload_props_opts_async_handle=reload_props_opts_async_handle,
271+
async_handle=async_handle,
280272
request_options=request_options,
281273
)
282274
return _response.data
@@ -286,7 +278,6 @@ def run(
286278
*,
287279
id: str,
288280
external_user_id: str,
289-
async_handle: typing.Optional[str] = None,
290281
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
291282
dynamic_props_id: typing.Optional[str] = OMIT,
292283
stash_id: typing.Optional[RunActionOptsStashId] = OMIT,
@@ -301,8 +292,6 @@ def run(
301292
external_user_id : str
302293
The external user ID
303294
304-
async_handle : typing.Optional[str]
305-
306295
configured_props : typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]]
307296
The configured properties for the action
308297
@@ -337,7 +326,6 @@ def run(
337326
_response = self._raw_client.run(
338327
id=id,
339328
external_user_id=external_user_id,
340-
async_handle=async_handle,
341329
configured_props=configured_props,
342330
dynamic_props_id=dynamic_props_id,
343331
stash_id=stash_id,
@@ -475,11 +463,10 @@ async def configure_prop(
475463
id: str,
476464
external_user_id: str,
477465
prop_name: str,
478-
async_handle: typing.Optional[str] = None,
479466
blocking: typing.Optional[bool] = OMIT,
480467
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
481468
dynamic_props_id: typing.Optional[str] = OMIT,
482-
configure_prop_opts_async_handle: typing.Optional[str] = OMIT,
469+
async_handle: typing.Optional[str] = OMIT,
483470
page: typing.Optional[float] = OMIT,
484471
prev_context: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
485472
query: typing.Optional[str] = OMIT,
@@ -497,8 +484,6 @@ async def configure_prop(
497484
prop_name : str
498485
The name of the prop to configure
499486
500-
async_handle : typing.Optional[str]
501-
502487
blocking : typing.Optional[bool]
503488
Whether this operation should block until completion
504489
@@ -508,7 +493,7 @@ async def configure_prop(
508493
dynamic_props_id : typing.Optional[str]
509494
The ID for dynamic props
510495
511-
configure_prop_opts_async_handle : typing.Optional[str]
496+
async_handle : typing.Optional[str]
512497
Handle for async operations
513498
514499
page : typing.Optional[float]
@@ -556,11 +541,10 @@ async def main() -> None:
556541
id=id,
557542
external_user_id=external_user_id,
558543
prop_name=prop_name,
559-
async_handle=async_handle,
560544
blocking=blocking,
561545
configured_props=configured_props,
562546
dynamic_props_id=dynamic_props_id,
563-
configure_prop_opts_async_handle=configure_prop_opts_async_handle,
547+
async_handle=async_handle,
564548
page=page,
565549
prev_context=prev_context,
566550
query=query,
@@ -573,11 +557,10 @@ async def reload_props(
573557
*,
574558
id: str,
575559
external_user_id: str,
576-
async_handle: typing.Optional[str] = None,
577560
blocking: typing.Optional[bool] = OMIT,
578561
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
579562
dynamic_props_id: typing.Optional[str] = OMIT,
580-
reload_props_opts_async_handle: typing.Optional[str] = OMIT,
563+
async_handle: typing.Optional[str] = OMIT,
581564
request_options: typing.Optional[RequestOptions] = None,
582565
) -> ReloadPropsResponse:
583566
"""
@@ -589,8 +572,6 @@ async def reload_props(
589572
external_user_id : str
590573
The external user ID
591574
592-
async_handle : typing.Optional[str]
593-
594575
blocking : typing.Optional[bool]
595576
Whether this operation should block until completion
596577
@@ -600,7 +581,7 @@ async def reload_props(
600581
dynamic_props_id : typing.Optional[str]
601582
The ID for dynamic props
602583
603-
reload_props_opts_async_handle : typing.Optional[str]
584+
async_handle : typing.Optional[str]
604585
Handle for async operations
605586
606587
request_options : typing.Optional[RequestOptions]
@@ -637,11 +618,10 @@ async def main() -> None:
637618
_response = await self._raw_client.reload_props(
638619
id=id,
639620
external_user_id=external_user_id,
640-
async_handle=async_handle,
641621
blocking=blocking,
642622
configured_props=configured_props,
643623
dynamic_props_id=dynamic_props_id,
644-
reload_props_opts_async_handle=reload_props_opts_async_handle,
624+
async_handle=async_handle,
645625
request_options=request_options,
646626
)
647627
return _response.data
@@ -651,7 +631,6 @@ async def run(
651631
*,
652632
id: str,
653633
external_user_id: str,
654-
async_handle: typing.Optional[str] = None,
655634
configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT,
656635
dynamic_props_id: typing.Optional[str] = OMIT,
657636
stash_id: typing.Optional[RunActionOptsStashId] = OMIT,
@@ -666,8 +645,6 @@ async def run(
666645
external_user_id : str
667646
The external user ID
668647
669-
async_handle : typing.Optional[str]
670-
671648
configured_props : typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]]
672649
The configured properties for the action
673650
@@ -710,7 +687,6 @@ async def main() -> None:
710687
_response = await self._raw_client.run(
711688
id=id,
712689
external_user_id=external_user_id,
713-
async_handle=async_handle,
714690
configured_props=configured_props,
715691
dynamic_props_id=dynamic_props_id,
716692
stash_id=stash_id,

0 commit comments

Comments
 (0)