return instead of yield in Consumer.consume

2022-03-24 09:58:18 +01:00 · 2022-03-24 09:58:18 +01:00 · 0206be8666
commit 0206be8666
parent 17e11adf78
1 changed files with 1 additions and 1 deletions
--- a/pyinfra/queue/consumer.py
+++ b/pyinfra/queue/consumer.py
@ -10,4 +10,4 @@ class Consumer:
        self.queue_manager.consume_and_publish(self.callback)

    def consume(self, **kwargs):
-        yield from self.queue_manager.consume(**kwargs)
+        return self.queue_manager.consume(**kwargs)