Asynchroneous close of response

alex-does-stuff · mattt · commit b7b3c5474fd3 · 2024-06-28T04:53:41.000-07:00
diff --git a/replicate/client.py b/replicate/client.py
@@ -305,7 +305,7 @@ async def handle_async_request(self, request: httpx.Request) -> httpx.Response:
             ):
                 return response
 
-            response.close()
+            await response.aclose()
 
             sleep_for = self._calculate_sleep(attempts_made, response.headers)
             await asyncio.sleep(sleep_for)
