diff --git a/kombu/transport/virtual/__init__.py b/kombu/transport/virtual/__init__.py index 84b5709c..b70e9e24 100644 --- a/kombu/transport/virtual/__init__.py +++ b/kombu/transport/virtual/__init__.py @@ -562,8 +562,6 @@ class Transport(base.Transport): channel.close() def drain_events(self, connection, timeout=None): - if not self.channels: - raise ValueError("No channels to drain events from.") loop = 0 time_start = time() while 1: