diff --git a/poetry.lock b/poetry.lock index c1c2313..c2ddd86 100644 --- a/poetry.lock +++ b/poetry.lock @@ -38,13 +38,13 @@ trio = ["trio (>=0.26.1)"] [[package]] name = "certifi" -version = "2025.7.14" +version = "2025.8.3" description = "Python package for providing Mozilla's CA Bundle." optional = false python-versions = ">=3.7" files = [ - {file = "certifi-2025.7.14-py3-none-any.whl", hash = "sha256:6b31f564a415d79ee77df69d757bb49a5bb53bd9f756cbbe24394ffd6fc1f4b2"}, - {file = "certifi-2025.7.14.tar.gz", hash = "sha256:8ea99dbdfaaf2ba2f9bac77b9249ef62ec5218e7c2b2e903378ed5fccf765995"}, + {file = "certifi-2025.8.3-py3-none-any.whl", hash = "sha256:f6c12493cfb1b06ba2ff328595af9350c65d6644968e5d3a2ffd78699af217a5"}, + {file = "certifi-2025.8.3.tar.gz", hash = "sha256:e564105f78ded564e3ae7c923924435e1daa7463faeab5bb932bc53ffae63407"}, ] [[package]] diff --git a/pyproject.toml b/pyproject.toml index 74906be..6faa1f2 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -3,7 +3,7 @@ name = "pipedream" [tool.poetry] name = "pipedream" -version = "1.0.2" +version = "1.0.3" description = "" readme = "README.md" authors = [] diff --git a/src/pipedream/actions/__init__.py b/src/pipedream/actions/__init__.py index 5cde020..ad121b7 100644 --- a/src/pipedream/actions/__init__.py +++ b/src/pipedream/actions/__init__.py @@ -2,3 +2,6 @@ # isort: skip_file +from .types import RunActionOptsStashId + +__all__ = ["RunActionOptsStashId"] diff --git a/src/pipedream/actions/client.py b/src/pipedream/actions/client.py index ad8161a..3a58b56 100644 --- a/src/pipedream/actions/client.py +++ b/src/pipedream/actions/client.py @@ -10,6 +10,7 @@ from ..types.reload_props_response import ReloadPropsResponse from ..types.run_action_response import RunActionResponse from .raw_client import AsyncRawActionsClient, RawActionsClient +from .types.run_action_opts_stash_id import RunActionOptsStashId # this is used as the default value for optional parameters OMIT = typing.cast(typing.Any, ...) @@ -288,6 +289,7 @@ def run( async_handle: typing.Optional[str] = None, configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT, dynamic_props_id: typing.Optional[str] = OMIT, + stash_id: typing.Optional[RunActionOptsStashId] = OMIT, request_options: typing.Optional[RequestOptions] = None, ) -> RunActionResponse: """ @@ -307,6 +309,9 @@ def run( dynamic_props_id : typing.Optional[str] The ID for dynamic props + stash_id : typing.Optional[RunActionOptsStashId] + The ID of the File Stash to use for syncing the action's /tmp directory + request_options : typing.Optional[RequestOptions] Request-specific configuration. @@ -336,6 +341,7 @@ def run( async_handle=async_handle, configured_props=configured_props, dynamic_props_id=dynamic_props_id, + stash_id=stash_id, request_options=request_options, ) return _response.data @@ -649,6 +655,7 @@ async def run( async_handle: typing.Optional[str] = None, configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT, dynamic_props_id: typing.Optional[str] = OMIT, + stash_id: typing.Optional[RunActionOptsStashId] = OMIT, request_options: typing.Optional[RequestOptions] = None, ) -> RunActionResponse: """ @@ -668,6 +675,9 @@ async def run( dynamic_props_id : typing.Optional[str] The ID for dynamic props + stash_id : typing.Optional[RunActionOptsStashId] + The ID of the File Stash to use for syncing the action's /tmp directory + request_options : typing.Optional[RequestOptions] Request-specific configuration. @@ -705,6 +715,7 @@ async def main() -> None: async_handle=async_handle, configured_props=configured_props, dynamic_props_id=dynamic_props_id, + stash_id=stash_id, request_options=request_options, ) return _response.data diff --git a/src/pipedream/actions/raw_client.py b/src/pipedream/actions/raw_client.py index 2465c23..7360b4b 100644 --- a/src/pipedream/actions/raw_client.py +++ b/src/pipedream/actions/raw_client.py @@ -10,12 +10,14 @@ from ..core.pagination import AsyncPager, BaseHttpResponse, SyncPager from ..core.pydantic_utilities import parse_obj_as from ..core.request_options import RequestOptions +from ..core.serialization import convert_and_respect_annotation_metadata from ..types.component import Component from ..types.configure_prop_response import ConfigurePropResponse from ..types.get_component_response import GetComponentResponse from ..types.get_components_response import GetComponentsResponse from ..types.reload_props_response import ReloadPropsResponse from ..types.run_action_response import RunActionResponse +from .types.run_action_opts_stash_id import RunActionOptsStashId # this is used as the default value for optional parameters OMIT = typing.cast(typing.Any, ...) @@ -322,6 +324,7 @@ def run( async_handle: typing.Optional[str] = None, configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT, dynamic_props_id: typing.Optional[str] = OMIT, + stash_id: typing.Optional[RunActionOptsStashId] = OMIT, request_options: typing.Optional[RequestOptions] = None, ) -> HttpResponse[RunActionResponse]: """ @@ -341,6 +344,9 @@ def run( dynamic_props_id : typing.Optional[str] The ID for dynamic props + stash_id : typing.Optional[RunActionOptsStashId] + The ID of the File Stash to use for syncing the action's /tmp directory + request_options : typing.Optional[RequestOptions] Request-specific configuration. @@ -357,6 +363,9 @@ def run( "external_user_id": external_user_id, "configured_props": configured_props, "dynamic_props_id": dynamic_props_id, + "stash_id": convert_and_respect_annotation_metadata( + object_=stash_id, annotation=RunActionOptsStashId, direction="write" + ), }, headers={ "content-type": "application/json", @@ -685,6 +694,7 @@ async def run( async_handle: typing.Optional[str] = None, configured_props: typing.Optional[typing.Dict[str, typing.Optional[typing.Any]]] = OMIT, dynamic_props_id: typing.Optional[str] = OMIT, + stash_id: typing.Optional[RunActionOptsStashId] = OMIT, request_options: typing.Optional[RequestOptions] = None, ) -> AsyncHttpResponse[RunActionResponse]: """ @@ -704,6 +714,9 @@ async def run( dynamic_props_id : typing.Optional[str] The ID for dynamic props + stash_id : typing.Optional[RunActionOptsStashId] + The ID of the File Stash to use for syncing the action's /tmp directory + request_options : typing.Optional[RequestOptions] Request-specific configuration. @@ -720,6 +733,9 @@ async def run( "external_user_id": external_user_id, "configured_props": configured_props, "dynamic_props_id": dynamic_props_id, + "stash_id": convert_and_respect_annotation_metadata( + object_=stash_id, annotation=RunActionOptsStashId, direction="write" + ), }, headers={ "content-type": "application/json", diff --git a/src/pipedream/actions/types/__init__.py b/src/pipedream/actions/types/__init__.py new file mode 100644 index 0000000..52a8a91 --- /dev/null +++ b/src/pipedream/actions/types/__init__.py @@ -0,0 +1,7 @@ +# This file was auto-generated by Fern from our API Definition. + +# isort: skip_file + +from .run_action_opts_stash_id import RunActionOptsStashId + +__all__ = ["RunActionOptsStashId"] diff --git a/src/pipedream/actions/types/run_action_opts_stash_id.py b/src/pipedream/actions/types/run_action_opts_stash_id.py new file mode 100644 index 0000000..ff5baae --- /dev/null +++ b/src/pipedream/actions/types/run_action_opts_stash_id.py @@ -0,0 +1,5 @@ +# This file was auto-generated by Fern from our API Definition. + +import typing + +RunActionOptsStashId = typing.Union[str, bool] diff --git a/src/pipedream/core/client_wrapper.py b/src/pipedream/core/client_wrapper.py index 37cd8e2..fbfab9b 100644 --- a/src/pipedream/core/client_wrapper.py +++ b/src/pipedream/core/client_wrapper.py @@ -27,10 +27,10 @@ def __init__( def get_headers(self) -> typing.Dict[str, str]: headers: typing.Dict[str, str] = { - "User-Agent": "pipedream/1.0.2", + "User-Agent": "pipedream/1.0.3", "X-Fern-Language": "Python", "X-Fern-SDK-Name": "pipedream", - "X-Fern-SDK-Version": "1.0.2", + "X-Fern-SDK-Version": "1.0.3", **(self.get_custom_headers() or {}), } if self._project_environment is not None: