Fix missing timeout argument from client constructor

The low-level client classes already supported the `timeout` argument,
but our custom client wrappers don't. This change fixes that
discrepancy (see issue #244).

Author: jverce

pyproject.toml

@@ -4,7 +4,7 @@ dynamic = ["version"]
 
 [tool.poetry]
 name = "pipedream"
-version = "1.1.1"
+version = "1.1.2"
 description = ""
 readme = "README.md"
 authors = []

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.1.1",
+            "User-Agent": "pipedream/1.1.2",
             "X-Fern-Language": "Python",
             "X-Fern-SDK-Name": "pipedream",
-            "X-Fern-SDK-Version": "1.1.1",
+            "X-Fern-SDK-Version": "1.1.2",
             **(self.get_custom_headers() or {}),
         }
         if self._project_environment is not None:

src/pipedream/pipedream.py

@@ -28,6 +28,7 @@ def __init__(
         ),
         environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
         workflow_domain: Optional[str] = None,
+        timeout: Optional[float] = None,
     ):
         if not project_id:
             raise ValueError("Project ID is required")
@@ -38,6 +39,7 @@ def __init__(
                 project_environment=project_environment,
                 project_id=project_id,
                 token=(lambda: access_token),
+                timeout=timeout,
             )
         else:
             super().__init__(
@@ -46,6 +48,7 @@ def __init__(
                 project_id=project_id,
                 client_id=client_id,
                 client_secret=client_secret,
+                timeout=timeout,
             )
 
         if not workflow_domain:
@@ -79,6 +82,7 @@ def __init__(
         ),
         environment: PipedreamEnvironment = PipedreamEnvironment.PROD,
         workflow_domain: Optional[str] = None,
+        timeout: Optional[float] = None,
     ):
         if not project_id:
             raise ValueError("Project ID is required")
@@ -89,6 +93,7 @@ def __init__(
                 project_environment=project_environment,
                 project_id=project_id,
                 token=(lambda: access_token),
+                timeout=timeout,
             )
         else:
             super().__init__(
@@ -97,6 +102,7 @@ def __init__(
                 project_id=project_id,
                 client_id=client_id,
                 client_secret=client_secret,
+                timeout=timeout,
             )
 
         if not workflow_domain: