rm some defaults from base

Author: vdusek

src/apify_client/_resource_clients/_resource_client.py

@@ -193,7 +193,7 @@ def __init__(
             params=params,
         )
 
-    def _get(self, *, timeout: Timeout = 'long') -> dict | None:
+    def _get(self, *, timeout: Timeout) -> dict | None:
         """Perform a GET request for this resource, returning the parsed response or None if not found."""
         try:
             response = self._http_client.call(
@@ -207,7 +207,7 @@ def _get(self, *, timeout: Timeout = 'long') -> dict | None:
             catch_not_found_or_throw(exc)
             return None
 
-    def _update(self, *, timeout: Timeout = 'long', **kwargs: Any) -> dict:
+    def _update(self, *, timeout: Timeout, **kwargs: Any) -> dict:
         """Perform a PUT request to update this resource with the given fields."""
         response = self._http_client.call(
             url=self._build_url(),
@@ -218,7 +218,7 @@ def _update(self, *, timeout: Timeout = 'long', **kwargs: Any) -> dict:
         )
         return response_to_dict(response)
 
-    def _delete(self, *, timeout: Timeout = 'long') -> None:
+    def _delete(self, *, timeout: Timeout) -> None:
         """Perform a DELETE request to delete this resource, ignoring 404 errors."""
         try:
             self._http_client.call(
@@ -230,7 +230,7 @@ def _delete(self, *, timeout: Timeout = 'long') -> None:
         except ApifyApiError as exc:
             catch_not_found_or_throw(exc)
 
-    def _list(self, *, timeout: Timeout = 'long', **kwargs: Any) -> dict:
+    def _list(self, *, timeout: Timeout, **kwargs: Any) -> dict:
         """Perform a GET request to list resources."""
         response = self._http_client.call(
             url=self._build_url(),
@@ -240,7 +240,7 @@ def _list(self, *, timeout: Timeout = 'long', **kwargs: Any) -> dict:
         )
         return response_to_dict(response)
 
-    def _create(self, *, timeout: Timeout = 'long', **kwargs: Any) -> dict:
+    def _create(self, *, timeout: Timeout, **kwargs: Any) -> dict:
         """Perform a POST request to create a resource."""
         response = self._http_client.call(
             url=self._build_url(),
@@ -256,7 +256,7 @@ def _get_or_create(
         *,
         name: str | None = None,
         resource_fields: dict | None = None,
-        timeout: Timeout = 'long',
+        timeout: Timeout,
     ) -> dict:
         """Perform a POST request to get or create a named resource."""
         response = self._http_client.call(
@@ -270,10 +270,11 @@ def _get_or_create(
 
     def _wait_for_finish(
         self,
+        *,
         url: str,
         params: dict,
+        timeout: Timeout,
         wait_duration: timedelta | None = None,
-        timeout: Timeout = 'no_timeout',
     ) -> dict | None:
         """Wait synchronously for an Actor job (run or build) to finish.
 
@@ -283,8 +284,8 @@ def _wait_for_finish(
         Args:
             url: Full URL to the job endpoint.
             params: Base query parameters to include in each request.
-            wait_duration: Maximum time to wait (None = indefinite).
             timeout: Timeout for each individual HTTP request.
+            wait_duration: Maximum time to wait (None = indefinite).
 
         Returns:
             Job data dict when finished, or None if job doesn't exist after
@@ -372,7 +373,7 @@ def __init__(
             params=params,
         )
 
-    async def _get(self, *, timeout: Timeout = 'long') -> dict | None:
+    async def _get(self, *, timeout: Timeout) -> dict | None:
         """Perform a GET request for this resource, returning the parsed response or None if not found."""
         try:
             response = await self._http_client.call(
@@ -386,7 +387,7 @@ async def _get(self, *, timeout: Timeout = 'long') -> dict | None:
             catch_not_found_or_throw(exc)
             return None
 
-    async def _update(self, *, timeout: Timeout = 'long', **kwargs: Any) -> dict:
+    async def _update(self, *, timeout: Timeout, **kwargs: Any) -> dict:
         """Perform a PUT request to update this resource with the given fields."""
         response = await self._http_client.call(
             url=self._build_url(),
@@ -397,7 +398,7 @@ async def _update(self, *, timeout: Timeout = 'long', **kwargs: Any) -> dict:
         )
         return response_to_dict(response)
 
-    async def _delete(self, *, timeout: Timeout = 'long') -> None:
+    async def _delete(self, *, timeout: Timeout) -> None:
         """Perform a DELETE request to delete this resource, ignoring 404 errors."""
         try:
             await self._http_client.call(
@@ -409,7 +410,7 @@ async def _delete(self, *, timeout: Timeout = 'long') -> None:
         except ApifyApiError as exc:
             catch_not_found_or_throw(exc)
 
-    async def _list(self, *, timeout: Timeout = 'long', **kwargs: Any) -> dict:
+    async def _list(self, *, timeout: Timeout, **kwargs: Any) -> dict:
         """Perform a GET request to list resources."""
         response = await self._http_client.call(
             url=self._build_url(),
@@ -419,7 +420,7 @@ async def _list(self, *, timeout: Timeout = 'long', **kwargs: Any) -> dict:
         )
         return response_to_dict(response)
 
-    async def _create(self, *, timeout: Timeout = 'long', **kwargs: Any) -> dict:
+    async def _create(self, *, timeout: Timeout, **kwargs: Any) -> dict:
         """Perform a POST request to create a resource."""
         response = await self._http_client.call(
             url=self._build_url(),
@@ -435,7 +436,7 @@ async def _get_or_create(
         *,
         name: str | None = None,
         resource_fields: dict | None = None,
-        timeout: Timeout = 'long',
+        timeout: Timeout,
     ) -> dict:
         """Perform a POST request to get or create a named resource."""
         response = await self._http_client.call(
@@ -449,10 +450,11 @@ async def _get_or_create(
 
     async def _wait_for_finish(
         self,
+        *,
         url: str,
         params: dict,
+        timeout: Timeout,
         wait_duration: timedelta | None = None,
-        timeout: Timeout = 'no_timeout',
     ) -> dict | None:
         """Wait asynchronously for an Actor job (run or build) to finish.
 
@@ -462,8 +464,8 @@ async def _wait_for_finish(
         Args:
             url: Full URL to the job endpoint.
             params: Base query parameters to include in each request.
-            wait_duration: Maximum time to wait (None = indefinite).
             timeout: Timeout for each individual HTTP request.
+            wait_duration: Maximum time to wait (None = indefinite).
 
         Returns:
             Job data dict when finished, or None if job doesn't exist after