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}",