Skip to content
Open
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
7 changes: 4 additions & 3 deletions .fern/metadata.json
Original file line number Diff line number Diff line change
@@ -1,13 +1,14 @@
{
"cliVersion": "3.5.0",
"cliVersion": "3.29.1",
"generatorName": "fernapi/fern-python-sdk",
"generatorVersion": "4.45.0",
"generatorVersion": "4.46.6",
"generatorConfig": {
"client": {
"class_name": "Client",
"filename": "client.py",
"exported_class_name": "Pipedream",
"exported_filename": "pipedream.py"
}
}
},
"sdkVersion": "1.1.4"
}
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.3"
version = "1.1.4"
description = ""
readme = "README.md"
authors = []
Expand Down
4 changes: 2 additions & 2 deletions src/pipedream/actions/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ def list(
Returns
-------
SyncPager[Component, GetComponentsResponse]
behaves like registry=all
returns public + private without permission

Examples
--------
Expand Down Expand Up @@ -425,7 +425,7 @@ async def list(
Returns
-------
AsyncPager[Component, GetComponentsResponse]
behaves like registry=all
returns public + private without permission

Examples
--------
Expand Down
4 changes: 2 additions & 2 deletions src/pipedream/actions/raw_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ def list(
Returns
-------
SyncPager[Component, GetComponentsResponse]
behaves like registry=all
returns public + private without permission
"""
_response = self._client_wrapper.httpx_client.request(
f"v1/connect/{jsonable_encoder(self._client_wrapper._project_id)}/actions",
Expand Down Expand Up @@ -523,7 +523,7 @@ async def list(
Returns
-------
AsyncPager[Component, GetComponentsResponse]
behaves like registry=all
returns public + private without permission
"""
_response = await self._client_wrapper.httpx_client.request(
f"v1/connect/{jsonable_encoder(self._client_wrapper._project_id)}/actions",
Expand Down
14 changes: 13 additions & 1 deletion src/pipedream/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
import typing

import httpx
from .types.project_environment import ProjectEnvironment
from ._.types.project_environment import ProjectEnvironment
from .core.api_error import ApiError
from .core.client_wrapper import AsyncClientWrapper, SyncClientWrapper
from .core.oauth_token_provider import AsyncOAuthTokenProvider, OAuthTokenProvider
Expand Down Expand Up @@ -99,6 +99,7 @@ def __init__(
environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
project_id: str,
project_environment: typing.Optional[ProjectEnvironment] = os.getenv("PIPEDREAM_PROJECT_ENVIRONMENT"),
headers: typing.Optional[typing.Dict[str, str]] = None,
timeout: typing.Optional[float] = None,
follow_redirects: typing.Optional[bool] = True,
httpx_client: typing.Optional[httpx.Client] = None,
Expand All @@ -113,6 +114,7 @@ def __init__(
environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
project_id: str,
project_environment: typing.Optional[ProjectEnvironment] = os.getenv("PIPEDREAM_PROJECT_ENVIRONMENT"),
headers: typing.Optional[typing.Dict[str, str]] = None,
timeout: typing.Optional[float] = None,
follow_redirects: typing.Optional[bool] = True,
httpx_client: typing.Optional[httpx.Client] = None,
Expand All @@ -125,6 +127,7 @@ def __init__(
environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
project_id: str,
project_environment: typing.Optional[ProjectEnvironment] = os.getenv("PIPEDREAM_PROJECT_ENVIRONMENT"),
headers: typing.Optional[typing.Dict[str, str]] = None,
client_id: typing.Optional[str] = os.getenv("PIPEDREAM_CLIENT_ID"),
client_secret: typing.Optional[str] = os.getenv("PIPEDREAM_CLIENT_SECRET"),
token: typing.Optional[typing.Callable[[], str]] = None,
Expand All @@ -141,6 +144,7 @@ def __init__(
base_url=_get_base_url(base_url=base_url, environment=environment),
project_id=project_id,
project_environment=project_environment,
headers=headers,
httpx_client=httpx_client
if httpx_client is not None
else httpx.Client(timeout=_defaulted_timeout, follow_redirects=follow_redirects)
Expand All @@ -157,6 +161,7 @@ def __init__(
base_url=_get_base_url(base_url=base_url, environment=environment),
project_id=project_id,
project_environment=project_environment,
headers=headers,
httpx_client=httpx.Client(timeout=_defaulted_timeout, follow_redirects=follow_redirects)
if follow_redirects is not None
else httpx.Client(timeout=_defaulted_timeout),
Expand All @@ -167,6 +172,7 @@ def __init__(
base_url=_get_base_url(base_url=base_url, environment=environment),
project_id=project_id,
project_environment=project_environment,
headers=headers,
token=_token_getter_override if _token_getter_override is not None else oauth_token_provider.get_token,
httpx_client=httpx_client
if httpx_client is not None
Expand Down Expand Up @@ -369,6 +375,7 @@ def __init__(
environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
project_id: str,
project_environment: typing.Optional[ProjectEnvironment] = os.getenv("PIPEDREAM_PROJECT_ENVIRONMENT"),
headers: typing.Optional[typing.Dict[str, str]] = None,
timeout: typing.Optional[float] = None,
follow_redirects: typing.Optional[bool] = True,
httpx_client: typing.Optional[httpx.AsyncClient] = None,
Expand All @@ -383,6 +390,7 @@ def __init__(
environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
project_id: str,
project_environment: typing.Optional[ProjectEnvironment] = os.getenv("PIPEDREAM_PROJECT_ENVIRONMENT"),
headers: typing.Optional[typing.Dict[str, str]] = None,
timeout: typing.Optional[float] = None,
follow_redirects: typing.Optional[bool] = True,
httpx_client: typing.Optional[httpx.AsyncClient] = None,
Expand All @@ -395,6 +403,7 @@ def __init__(
environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
project_id: str,
project_environment: typing.Optional[ProjectEnvironment] = os.getenv("PIPEDREAM_PROJECT_ENVIRONMENT"),
headers: typing.Optional[typing.Dict[str, str]] = None,
client_id: typing.Optional[str] = os.getenv("PIPEDREAM_CLIENT_ID"),
client_secret: typing.Optional[str] = os.getenv("PIPEDREAM_CLIENT_SECRET"),
token: typing.Optional[typing.Callable[[], str]] = None,
Expand All @@ -411,6 +420,7 @@ def __init__(
base_url=_get_base_url(base_url=base_url, environment=environment),
project_id=project_id,
project_environment=project_environment,
headers=headers,
httpx_client=httpx_client
if httpx_client is not None
else httpx.AsyncClient(timeout=_defaulted_timeout, follow_redirects=follow_redirects)
Expand All @@ -427,6 +437,7 @@ def __init__(
base_url=_get_base_url(base_url=base_url, environment=environment),
project_id=project_id,
project_environment=project_environment,
headers=headers,
httpx_client=httpx.AsyncClient(timeout=_defaulted_timeout, follow_redirects=follow_redirects)
if follow_redirects is not None
else httpx.AsyncClient(timeout=_defaulted_timeout),
Expand All @@ -437,6 +448,7 @@ def __init__(
base_url=_get_base_url(base_url=base_url, environment=environment),
project_id=project_id,
project_environment=project_environment,
headers=headers,
token=_token_getter_override,
async_token=oauth_token_provider.get_token,
httpx_client=httpx_client
Expand Down
4 changes: 2 additions & 2 deletions src/pipedream/components/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ def list(
Returns
-------
SyncPager[Component, GetComponentsResponse]
behaves like registry=all
returns public + private without permission

Examples
--------
Expand Down Expand Up @@ -374,7 +374,7 @@ async def list(
Returns
-------
AsyncPager[Component, GetComponentsResponse]
behaves like registry=all
returns public + private without permission

Examples
--------
Expand Down
4 changes: 2 additions & 2 deletions src/pipedream/components/raw_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ def list(
Returns
-------
SyncPager[Component, GetComponentsResponse]
behaves like registry=all
returns public + private without permission
"""
_response = self._client_wrapper.httpx_client.request(
f"v1/connect/{jsonable_encoder(self._client_wrapper._project_id)}/components",
Expand Down Expand Up @@ -445,7 +445,7 @@ async def list(
Returns
-------
AsyncPager[Component, GetComponentsResponse]
behaves like registry=all
returns public + private without permission
"""
_response = await self._client_wrapper.httpx_client.request(
f"v1/connect/{jsonable_encoder(self._client_wrapper._project_id)}/components",
Expand Down
6 changes: 3 additions & 3 deletions src/pipedream/core/client_wrapper.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
import typing

import httpx
from ..types.project_environment import ProjectEnvironment
from .._.types.project_environment import ProjectEnvironment
from .http_client import AsyncHttpClient, HttpClient


Expand All @@ -27,10 +27,10 @@ def __init__(

def get_headers(self) -> typing.Dict[str, str]:
headers: typing.Dict[str, str] = {
"User-Agent": "pipedream/1.1.3",
"User-Agent": "pipedream/1.1.4",
"X-Fern-Language": "Python",
"X-Fern-SDK-Name": "pipedream",
"X-Fern-SDK-Version": "1.1.3",
"X-Fern-SDK-Version": "1.1.4",
**(self.get_custom_headers() or {}),
}
if self._project_environment is not None:
Expand Down
Loading
Loading