From 0a8b7e52260bcd7fa033c16f2d29957f3727bb94 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mat=C4=9Bj=20Volf?= Date: Thu, 8 Jan 2026 16:09:32 +0100 Subject: [PATCH] fix: fetch key-value store records as attachments --- .../clients/resource_clients/key_value_store.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/apify_client/clients/resource_clients/key_value_store.py b/src/apify_client/clients/resource_clients/key_value_store.py index 46d415f1..47bc7003 100644 --- a/src/apify_client/clients/resource_clients/key_value_store.py +++ b/src/apify_client/clients/resource_clients/key_value_store.py @@ -126,7 +126,7 @@ def get_record(self, key: str, signature: str | None = None) -> dict | None: response = self.http_client.call( url=self._url(f'records/{key}'), method='GET', - params=self._params(signature=signature), + params=self._params(signature=signature, attachment=True), ) return { @@ -181,7 +181,7 @@ def get_record_as_bytes(self, key: str, signature: str | None = None) -> dict | response = self.http_client.call( url=self._url(f'records/{key}'), method='GET', - params=self._params(signature=signature), + params=self._params(signature=signature, attachment=True), ) return { @@ -213,7 +213,7 @@ def stream_record(self, key: str, signature: str | None = None) -> Iterator[dict response = self.http_client.call( url=self._url(f'records/{key}'), method='GET', - params=self._params(signature=signature), + params=self._params(signature=signature, attachment=True), stream=True, ) @@ -450,7 +450,7 @@ async def get_record(self, key: str, signature: str | None = None) -> dict | Non response = await self.http_client.call( url=self._url(f'records/{key}'), method='GET', - params=self._params(signature=signature), + params=self._params(signature=signature, attachment=True), ) return { @@ -505,7 +505,7 @@ async def get_record_as_bytes(self, key: str, signature: str | None = None) -> d response = await self.http_client.call( url=self._url(f'records/{key}'), method='GET', - params=self._params(signature=signature), + params=self._params(signature=signature, attachment=True), ) return { @@ -537,7 +537,7 @@ async def stream_record(self, key: str, signature: str | None = None) -> AsyncIt response = await self.http_client.call( url=self._url(f'records/{key}'), method='GET', - params=self._params(signature=signature), + params=self._params(signature=signature, attachment=True), stream=True, )