diff options
| -rw-r--r-- | nova/rpc/impl_kombu.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/nova/rpc/impl_kombu.py b/nova/rpc/impl_kombu.py index 74c8cf412..1b80fce04 100644 --- a/nova/rpc/impl_kombu.py +++ b/nova/rpc/impl_kombu.py @@ -682,6 +682,8 @@ class MulticallWaiter(object): def done(self): self._done = True + self._iterator.close() + self._iterator = None self._connection.close() def __call__(self, data): |