From b4434c1d5da2c5a92c0994b5777230e04e28a665 Mon Sep 17 00:00:00 2001 From: Dylan McReynolds Date: Tue, 31 Mar 2026 17:59:12 -0700 Subject: [PATCH] fix operator --- src/arroyopy/operator.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/arroyopy/operator.py b/src/arroyopy/operator.py index bea8a95..2e2795e 100644 --- a/src/arroyopy/operator.py +++ b/src/arroyopy/operator.py @@ -47,6 +47,6 @@ async def start(self): for listener in self.listeners: await listener.stop() break - message = await self.queue.get() + message = await self.listener_queue.get() processed_message = await self.process(message) await self.publish(processed_message)