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
3 changes: 3 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -112,6 +112,9 @@ response = client.apps.list(
q="q",
sort_key="name",
sort_direction="asc",
has_components=True,
has_actions=True,
has_triggers=True,
)
for item in response:
yield item
Expand Down
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ dynamic = ["version"]

[tool.poetry]
name = "pipedream"
version = "1.1.0"
version = "1.1.1"
description = ""
readme = "README.md"
authors = []
Expand Down
36 changes: 36 additions & 0 deletions src/pipedream/apps/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,9 @@ def list(
sort_key: typing.Optional[AppsListRequestSortKey] = None,
sort_direction: typing.Optional[AppsListRequestSortDirection] = None,
category_ids: typing.Optional[typing.Union[str, typing.Sequence[str]]] = None,
has_components: typing.Optional[bool] = None,
has_actions: typing.Optional[bool] = None,
has_triggers: typing.Optional[bool] = None,
request_options: typing.Optional[RequestOptions] = None,
) -> SyncPager[App, ListAppsResponse]:
"""
Expand Down Expand Up @@ -66,6 +69,15 @@ def list(
category_ids : typing.Optional[typing.Union[str, typing.Sequence[str]]]
Only return apps in these categories

has_components : typing.Optional[bool]
Filter to apps that have components (actions or triggers)

has_actions : typing.Optional[bool]
Filter to apps that have actions

has_triggers : typing.Optional[bool]
Filter to apps that have triggers

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

Expand All @@ -91,6 +103,9 @@ def list(
q="q",
sort_key="name",
sort_direction="asc",
has_components=True,
has_actions=True,
has_triggers=True,
)
for item in response:
yield item
Expand All @@ -106,6 +121,9 @@ def list(
sort_key=sort_key,
sort_direction=sort_direction,
category_ids=category_ids,
has_components=has_components,
has_actions=has_actions,
has_triggers=has_triggers,
request_options=request_options,
)

Expand Down Expand Up @@ -169,6 +187,9 @@ async def list(
sort_key: typing.Optional[AppsListRequestSortKey] = None,
sort_direction: typing.Optional[AppsListRequestSortDirection] = None,
category_ids: typing.Optional[typing.Union[str, typing.Sequence[str]]] = None,
has_components: typing.Optional[bool] = None,
has_actions: typing.Optional[bool] = None,
has_triggers: typing.Optional[bool] = None,
request_options: typing.Optional[RequestOptions] = None,
) -> AsyncPager[App, ListAppsResponse]:
"""
Expand Down Expand Up @@ -197,6 +218,15 @@ async def list(
category_ids : typing.Optional[typing.Union[str, typing.Sequence[str]]]
Only return apps in these categories

has_components : typing.Optional[bool]
Filter to apps that have components (actions or triggers)

has_actions : typing.Optional[bool]
Filter to apps that have actions

has_triggers : typing.Optional[bool]
Filter to apps that have triggers

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

Expand Down Expand Up @@ -227,6 +257,9 @@ async def main() -> None:
q="q",
sort_key="name",
sort_direction="asc",
has_components=True,
has_actions=True,
has_triggers=True,
)
async for item in response:
yield item
Expand All @@ -246,6 +279,9 @@ async def main() -> None:
sort_key=sort_key,
sort_direction=sort_direction,
category_ids=category_ids,
has_components=has_components,
has_actions=has_actions,
has_triggers=has_triggers,
request_options=request_options,
)

Expand Down
36 changes: 36 additions & 0 deletions src/pipedream/apps/raw_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,9 @@ def list(
sort_key: typing.Optional[AppsListRequestSortKey] = None,
sort_direction: typing.Optional[AppsListRequestSortDirection] = None,
category_ids: typing.Optional[typing.Union[str, typing.Sequence[str]]] = None,
has_components: typing.Optional[bool] = None,
has_actions: typing.Optional[bool] = None,
has_triggers: typing.Optional[bool] = None,
request_options: typing.Optional[RequestOptions] = None,
) -> SyncPager[App, ListAppsResponse]:
"""
Expand Down Expand Up @@ -59,6 +62,15 @@ def list(
category_ids : typing.Optional[typing.Union[str, typing.Sequence[str]]]
Only return apps in these categories

has_components : typing.Optional[bool]
Filter to apps that have components (actions or triggers)

has_actions : typing.Optional[bool]
Filter to apps that have actions

has_triggers : typing.Optional[bool]
Filter to apps that have triggers

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

Expand All @@ -78,6 +90,9 @@ def list(
"sort_key": sort_key,
"sort_direction": sort_direction,
"category_ids": category_ids,
"has_components": has_components,
"has_actions": has_actions,
"has_triggers": has_triggers,
},
request_options=request_options,
)
Expand All @@ -104,6 +119,9 @@ def list(
sort_key=sort_key,
sort_direction=sort_direction,
category_ids=category_ids,
has_components=has_components,
has_actions=has_actions,
has_triggers=has_triggers,
request_options=request_options,
)
return SyncPager(has_next=_has_next, items=_items, get_next=_get_next, response=_parsed_response)
Expand Down Expand Up @@ -166,6 +184,9 @@ async def list(
sort_key: typing.Optional[AppsListRequestSortKey] = None,
sort_direction: typing.Optional[AppsListRequestSortDirection] = None,
category_ids: typing.Optional[typing.Union[str, typing.Sequence[str]]] = None,
has_components: typing.Optional[bool] = None,
has_actions: typing.Optional[bool] = None,
has_triggers: typing.Optional[bool] = None,
request_options: typing.Optional[RequestOptions] = None,
) -> AsyncPager[App, ListAppsResponse]:
"""
Expand Down Expand Up @@ -194,6 +215,15 @@ async def list(
category_ids : typing.Optional[typing.Union[str, typing.Sequence[str]]]
Only return apps in these categories

has_components : typing.Optional[bool]
Filter to apps that have components (actions or triggers)

has_actions : typing.Optional[bool]
Filter to apps that have actions

has_triggers : typing.Optional[bool]
Filter to apps that have triggers

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

Expand All @@ -213,6 +243,9 @@ async def list(
"sort_key": sort_key,
"sort_direction": sort_direction,
"category_ids": category_ids,
"has_components": has_components,
"has_actions": has_actions,
"has_triggers": has_triggers,
},
request_options=request_options,
)
Expand Down Expand Up @@ -241,6 +274,9 @@ async def _get_next():
sort_key=sort_key,
sort_direction=sort_direction,
category_ids=category_ids,
has_components=has_components,
has_actions=has_actions,
has_triggers=has_triggers,
request_options=request_options,
)

Expand Down
4 changes: 2 additions & 2 deletions src/pipedream/core/client_wrapper.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,10 +27,10 @@ def __init__(

def get_headers(self) -> typing.Dict[str, str]:
headers: typing.Dict[str, str] = {
"User-Agent": "pipedream/1.1.0",
"User-Agent": "pipedream/1.1.1",
"X-Fern-Language": "Python",
"X-Fern-SDK-Name": "pipedream",
"X-Fern-SDK-Version": "1.1.0",
"X-Fern-SDK-Version": "1.1.1",
**(self.get_custom_headers() or {}),
}
if self._project_environment is not None:
Expand Down
42 changes: 38 additions & 4 deletions src/pipedream/projects/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,7 @@ def create(
name: str,
app_name: typing.Optional[str] = OMIT,
support_email: typing.Optional[str] = OMIT,
connect_require_key_auth_test: typing.Optional[bool] = OMIT,
request_options: typing.Optional[RequestOptions] = None,
) -> Project:
"""
Expand All @@ -109,6 +110,9 @@ def create(
support_email : typing.Optional[str]
Support email displayed to end users

connect_require_key_auth_test : typing.Optional[bool]
Send a test request to the upstream API when adding Connect accounts for key-based apps

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

Expand All @@ -132,7 +136,11 @@ def create(
)
"""
_response = self._raw_client.create(
name=name, app_name=app_name, support_email=support_email, request_options=request_options
name=name,
app_name=app_name,
support_email=support_email,
connect_require_key_auth_test=connect_require_key_auth_test,
request_options=request_options,
)
return _response.data

Expand Down Expand Up @@ -210,6 +218,7 @@ def update(
name: typing.Optional[str] = OMIT,
app_name: typing.Optional[str] = OMIT,
support_email: typing.Optional[str] = OMIT,
connect_require_key_auth_test: typing.Optional[bool] = OMIT,
request_options: typing.Optional[RequestOptions] = None,
) -> Project:
"""
Expand All @@ -229,6 +238,9 @@ def update(
support_email : typing.Optional[str]
Support email displayed to end users

connect_require_key_auth_test : typing.Optional[bool]
Send a test request to the upstream API when adding Connect accounts for key-based apps

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

Expand All @@ -252,7 +264,12 @@ def update(
)
"""
_response = self._raw_client.update(
project_id, name=name, app_name=app_name, support_email=support_email, request_options=request_options
project_id,
name=name,
app_name=app_name,
support_email=support_email,
connect_require_key_auth_test=connect_require_key_auth_test,
request_options=request_options,
)
return _response.data

Expand Down Expand Up @@ -415,6 +432,7 @@ async def create(
name: str,
app_name: typing.Optional[str] = OMIT,
support_email: typing.Optional[str] = OMIT,
connect_require_key_auth_test: typing.Optional[bool] = OMIT,
request_options: typing.Optional[RequestOptions] = None,
) -> Project:
"""
Expand All @@ -431,6 +449,9 @@ async def create(
support_email : typing.Optional[str]
Support email displayed to end users

connect_require_key_auth_test : typing.Optional[bool]
Send a test request to the upstream API when adding Connect accounts for key-based apps

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

Expand Down Expand Up @@ -462,7 +483,11 @@ async def main() -> None:
asyncio.run(main())
"""
_response = await self._raw_client.create(
name=name, app_name=app_name, support_email=support_email, request_options=request_options
name=name,
app_name=app_name,
support_email=support_email,
connect_require_key_auth_test=connect_require_key_auth_test,
request_options=request_options,
)
return _response.data

Expand Down Expand Up @@ -556,6 +581,7 @@ async def update(
name: typing.Optional[str] = OMIT,
app_name: typing.Optional[str] = OMIT,
support_email: typing.Optional[str] = OMIT,
connect_require_key_auth_test: typing.Optional[bool] = OMIT,
request_options: typing.Optional[RequestOptions] = None,
) -> Project:
"""
Expand All @@ -575,6 +601,9 @@ async def update(
support_email : typing.Optional[str]
Support email displayed to end users

connect_require_key_auth_test : typing.Optional[bool]
Send a test request to the upstream API when adding Connect accounts for key-based apps

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

Expand Down Expand Up @@ -606,7 +635,12 @@ async def main() -> None:
asyncio.run(main())
"""
_response = await self._raw_client.update(
project_id, name=name, app_name=app_name, support_email=support_email, request_options=request_options
project_id,
name=name,
app_name=app_name,
support_email=support_email,
connect_require_key_auth_test=connect_require_key_auth_test,
request_options=request_options,
)
return _response.data

Expand Down
Loading