Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ name = "pipedream"

[tool.poetry]
name = "pipedream"
version = "1.0.10"
version = "1.0.11"
description = ""
readme = "README.md"
authors = []
Expand Down
56 changes: 52 additions & 4 deletions src/pipedream/actions/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,13 @@ def list(
after=after, before=before, limit=limit, q=q, app=app, request_options=request_options
)

def retrieve(self, component_id: str, *, request_options: typing.Optional[RequestOptions] = None) -> Component:
def retrieve(
self,
component_id: str,
*,
version: typing.Optional[str] = None,
request_options: typing.Optional[RequestOptions] = None,
) -> Component:
"""
Get detailed configuration for a specific action by its key

Expand All @@ -106,6 +112,9 @@ def retrieve(self, component_id: str, *, request_options: typing.Optional[Reques
component_id : str
The key that uniquely identifies the component (e.g., 'slack-send-message')

version : typing.Optional[str]
Optional semantic version of the component to retrieve (for example '1.0.0')

request_options : typing.Optional[RequestOptions]
Request-specific configuration.

Expand All @@ -126,9 +135,10 @@ def retrieve(self, component_id: str, *, request_options: typing.Optional[Reques
)
client.actions.retrieve(
component_id="component_id",
version="1.2.3",
)
"""
_response = self._raw_client.retrieve(component_id, request_options=request_options)
_response = self._raw_client.retrieve(component_id, version=version, request_options=request_options)
return _response.data

def configure_prop(
Expand All @@ -137,6 +147,7 @@ def configure_prop(
id: str,
external_user_id: str,
prop_name: str,
version: typing.Optional[str] = OMIT,
blocking: typing.Optional[bool] = OMIT,
configured_props: typing.Optional[ConfiguredProps] = OMIT,
dynamic_props_id: typing.Optional[str] = OMIT,
Expand All @@ -159,6 +170,9 @@ def configure_prop(
prop_name : str
The name of the prop to configure

version : typing.Optional[str]
Optional component version (in SemVer format, for example '1.0.0'), defaults to latest

blocking : typing.Optional[bool]
Whether this operation should block until completion

Expand Down Expand Up @@ -204,6 +218,7 @@ def configure_prop(
id=id,
external_user_id=external_user_id,
prop_name=prop_name,
version=version,
blocking=blocking,
configured_props=configured_props,
dynamic_props_id=dynamic_props_id,
Expand All @@ -219,6 +234,7 @@ def reload_props(
*,
id: str,
external_user_id: str,
version: typing.Optional[str] = OMIT,
blocking: typing.Optional[bool] = OMIT,
configured_props: typing.Optional[ConfiguredProps] = OMIT,
dynamic_props_id: typing.Optional[str] = OMIT,
Expand All @@ -235,6 +251,9 @@ def reload_props(
external_user_id : str
The external user ID

version : typing.Optional[str]
Optional component version (in SemVer format, for example '1.0.0'), defaults to latest

blocking : typing.Optional[bool]
Whether this operation should block until completion

Expand Down Expand Up @@ -269,6 +288,7 @@ def reload_props(
_response = self._raw_client.reload_props(
id=id,
external_user_id=external_user_id,
version=version,
blocking=blocking,
configured_props=configured_props,
dynamic_props_id=dynamic_props_id,
Expand All @@ -281,6 +301,7 @@ def run(
*,
id: str,
external_user_id: str,
version: typing.Optional[str] = OMIT,
configured_props: typing.Optional[ConfiguredProps] = OMIT,
dynamic_props_id: typing.Optional[str] = OMIT,
stash_id: typing.Optional[RunActionOptsStashId] = OMIT,
Expand All @@ -297,6 +318,9 @@ def run(
external_user_id : str
The external user ID

version : typing.Optional[str]
Optional action component version (in SemVer format, for example '1.0.0'), defaults to latest

configured_props : typing.Optional[ConfiguredProps]

dynamic_props_id : typing.Optional[str]
Expand Down Expand Up @@ -330,6 +354,7 @@ def run(
_response = self._raw_client.run(
id=id,
external_user_id=external_user_id,
version=version,
configured_props=configured_props,
dynamic_props_id=dynamic_props_id,
stash_id=stash_id,
Expand Down Expand Up @@ -428,7 +453,11 @@ async def main() -> None:
)

async def retrieve(
self, component_id: str, *, request_options: typing.Optional[RequestOptions] = None
self,
component_id: str,
*,
version: typing.Optional[str] = None,
request_options: typing.Optional[RequestOptions] = None,
) -> Component:
"""
Get detailed configuration for a specific action by its key
Expand All @@ -438,6 +467,9 @@ async def retrieve(
component_id : str
The key that uniquely identifies the component (e.g., 'slack-send-message')

version : typing.Optional[str]
Optional semantic version of the component to retrieve (for example '1.0.0')

request_options : typing.Optional[RequestOptions]
Request-specific configuration.

Expand All @@ -463,12 +495,13 @@ async def retrieve(
async def main() -> None:
await client.actions.retrieve(
component_id="component_id",
version="1.2.3",
)


asyncio.run(main())
"""
_response = await self._raw_client.retrieve(component_id, request_options=request_options)
_response = await self._raw_client.retrieve(component_id, version=version, request_options=request_options)
return _response.data

async def configure_prop(
Expand All @@ -477,6 +510,7 @@ async def configure_prop(
id: str,
external_user_id: str,
prop_name: str,
version: typing.Optional[str] = OMIT,
blocking: typing.Optional[bool] = OMIT,
configured_props: typing.Optional[ConfiguredProps] = OMIT,
dynamic_props_id: typing.Optional[str] = OMIT,
Expand All @@ -499,6 +533,9 @@ async def configure_prop(
prop_name : str
The name of the prop to configure

version : typing.Optional[str]
Optional component version (in SemVer format, for example '1.0.0'), defaults to latest

blocking : typing.Optional[bool]
Whether this operation should block until completion

Expand Down Expand Up @@ -552,6 +589,7 @@ async def main() -> None:
id=id,
external_user_id=external_user_id,
prop_name=prop_name,
version=version,
blocking=blocking,
configured_props=configured_props,
dynamic_props_id=dynamic_props_id,
Expand All @@ -567,6 +605,7 @@ async def reload_props(
*,
id: str,
external_user_id: str,
version: typing.Optional[str] = OMIT,
blocking: typing.Optional[bool] = OMIT,
configured_props: typing.Optional[ConfiguredProps] = OMIT,
dynamic_props_id: typing.Optional[str] = OMIT,
Expand All @@ -583,6 +622,9 @@ async def reload_props(
external_user_id : str
The external user ID

version : typing.Optional[str]
Optional component version (in SemVer format, for example '1.0.0'), defaults to latest

blocking : typing.Optional[bool]
Whether this operation should block until completion

Expand Down Expand Up @@ -625,6 +667,7 @@ async def main() -> None:
_response = await self._raw_client.reload_props(
id=id,
external_user_id=external_user_id,
version=version,
blocking=blocking,
configured_props=configured_props,
dynamic_props_id=dynamic_props_id,
Expand All @@ -637,6 +680,7 @@ async def run(
*,
id: str,
external_user_id: str,
version: typing.Optional[str] = OMIT,
configured_props: typing.Optional[ConfiguredProps] = OMIT,
dynamic_props_id: typing.Optional[str] = OMIT,
stash_id: typing.Optional[RunActionOptsStashId] = OMIT,
Expand All @@ -653,6 +697,9 @@ async def run(
external_user_id : str
The external user ID

version : typing.Optional[str]
Optional action component version (in SemVer format, for example '1.0.0'), defaults to latest

configured_props : typing.Optional[ConfiguredProps]

dynamic_props_id : typing.Optional[str]
Expand Down Expand Up @@ -694,6 +741,7 @@ async def main() -> None:
_response = await self._raw_client.run(
id=id,
external_user_id=external_user_id,
version=version,
configured_props=configured_props,
dynamic_props_id=dynamic_props_id,
stash_id=stash_id,
Expand Down
Loading