diff --git a/kubernetes_asyncio/watch/watch.py b/kubernetes_asyncio/watch/watch.py index 45c2754c9..1bb131a62 100644 --- a/kubernetes_asyncio/watch/watch.py +++ b/kubernetes_asyncio/watch/watch.py @@ -128,6 +128,7 @@ async def next(self): line = await self.resp.content.readline() except asyncio.TimeoutError: if 'timeout_seconds' not in self.func.keywords: + self.resp.close() self.resp = None self.func.keywords['resource_version'] = self.resource_version continue