From 6001a2ca5d6e5404b2c1ee804ec2e78f93c660a6 Mon Sep 17 00:00:00 2001 From: Chenyme <118253778+chenyme@users.noreply.github.com> Date: Tue, 17 Feb 2026 23:14:49 +0800 Subject: [PATCH] feat: enable streaming for file uploads in UploadService --- app/services/grok/utils/upload.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/app/services/grok/utils/upload.py b/app/services/grok/utils/upload.py index 0861a4ed..ff5cb7ee 100644 --- a/app/services/grok/utils/upload.py +++ b/app/services/grok/utils/upload.py @@ -142,7 +142,9 @@ async def parse_b64(self, url: str) -> Tuple[str, str, str]: lock_timeout = max(1, int(get_config("asset.upload_timeout"))) async with _file_lock(lock_name, timeout=lock_timeout): session = await self.create() - response = await session.get(url, timeout=timeout, proxies=proxies) + response = await session.get( + url, timeout=timeout, proxies=proxies, stream=True + ) if response.status_code >= 400: raise UpstreamException( message=f"Failed to fetch: {response.status_code}",