Merge remote-tracking branch 'origin/master' into redirect-status-messages

Author: Pijukatel

CHANGELOG.md

@@ -8,6 +8,8 @@ All notable changes to this project will be documented in this file.
 ### 🚀 Features
 
 - Add `validate_input` endpoint ([#396](https://github.com/apify/apify-client-python/pull/396)) ([1c5bf85](https://github.com/apify/apify-client-python/commit/1c5bf8550ffd91b94ea83694f7c933cf2767fadc)) by [@Pijukatel](https://github.com/Pijukatel), closes [#151](https://github.com/apify/apify-client-python/issues/151)
+- Add list kv store keys by collection or prefix ([#397](https://github.com/apify/apify-client-python/pull/397)) ([6747c20](https://github.com/apify/apify-client-python/commit/6747c201cd654953a97a4c3fe8256756eb7568c7)) by [@MFori](https://github.com/MFori)
+- Add redirected actor logs ([#403](https://github.com/apify/apify-client-python/pull/403)) ([fd02cd8](https://github.com/apify/apify-client-python/commit/fd02cd8726f1664677a47dcb946a0186080d7839)) by [@Pijukatel](https://github.com/Pijukatel), closes [#402](https://github.com/apify/apify-client-python/issues/402)
 
 
 <!-- git-cliff-unreleased-end -->

src/apify_client/clients/resource_clients/key_value_store.py

@@ -63,19 +63,33 @@ def delete(self) -> None:
         """
         return self._delete(timeout_secs=_SMALL_TIMEOUT)
 
-    def list_keys(self, *, limit: int | None = None, exclusive_start_key: str | None = None) -> dict:
+    def list_keys(
+        self,
+        *,
+        limit: int | None = None,
+        exclusive_start_key: str | None = None,
+        collection: str | None = None,
+        prefix: str | None = None,
+    ) -> dict:
         """List the keys in the key-value store.
 
         https://docs.apify.com/api/v2#/reference/key-value-stores/key-collection/get-list-of-keys
 
         Args:
             limit: Number of keys to be returned. Maximum value is 1000.
             exclusive_start_key: All keys up to this one (including) are skipped from the result.
+            collection: The name of the collection in store schema to list keys from.
+            prefix: The prefix of the keys to be listed.
 
         Returns:
             The list of keys in the key-value store matching the given arguments.
         """
-        request_params = self._params(limit=limit, exclusiveStartKey=exclusive_start_key)
+        request_params = self._params(
+            limit=limit,
+            exclusiveStartKey=exclusive_start_key,
+            collection=collection,
+            prefix=prefix,
+        )
 
         response = self.http_client.call(
             url=self._url('keys'),
@@ -292,19 +306,33 @@ async def delete(self) -> None:
         """
         return await self._delete(timeout_secs=_SMALL_TIMEOUT)
 
-    async def list_keys(self, *, limit: int | None = None, exclusive_start_key: str | None = None) -> dict:
+    async def list_keys(
+        self,
+        *,
+        limit: int | None = None,
+        exclusive_start_key: str | None = None,
+        collection: str | None = None,
+        prefix: str | None = None,
+    ) -> dict:
         """List the keys in the key-value store.
 
         https://docs.apify.com/api/v2#/reference/key-value-stores/key-collection/get-list-of-keys
 
         Args:
             limit: Number of keys to be returned. Maximum value is 1000.
             exclusive_start_key: All keys up to this one (including) are skipped from the result.
+            collection: The name of the collection in store schema to list keys from.
+            prefix: The prefix of the keys to be listed.
 
         Returns:
             The list of keys in the key-value store matching the given arguments.
         """
-        request_params = self._params(limit=limit, exclusiveStartKey=exclusive_start_key)
+        request_params = self._params(
+            limit=limit,
+            exclusiveStartKey=exclusive_start_key,
+            collection=collection,
+            prefix=prefix,
+        )
 
         response = await self.http_client.call(
             url=self._url('keys'),