From 0206be86669c9f4b70bb21d416d6f10ce5e8731a Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Thu, 24 Mar 2022 09:58:18 +0100 Subject: [PATCH] return instead of yield in Consumer.consume --- pyinfra/queue/consumer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pyinfra/queue/consumer.py b/pyinfra/queue/consumer.py index a446b85..c21cb26 100644 --- 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)