MOTOR-185 Deadlock closing Change Stream

2018-01-10 09:25:56 -05:00 · 2018-01-10 09:25:56 -05:00 · 08ef305847
commit 08ef305847
parent 78271b9693
1 changed files with 2 additions and 1 deletions
--- a/motor/core.py
+++ b/motor/core.py
@ -1313,7 +1313,8 @@ class AgnosticChangeStream(AgnosticBase):
            return self
    
        async def __aexit__(self, exc_type, exc_val, exc_tb):
-            await self.close()
+            if self.delegate:
+                self.delegate.close() 
        """), globals(), locals())

    def get_io_loop(self):