From a2856b10e9239d2e9a0792fc8dc767b8cea5cf47 Mon Sep 17 00:00:00 2001 From: Dawid Deja Date: Wed, 8 Feb 2017 12:01:41 +0100 Subject: [PATCH] Fix for failing services on py3 with kombu driver Change-Id: I41f6cfbbe965cc1430b8711de6a09f99c9ca011e Closes-bug: 1661201 --- mistral/engine/rpc_backend/kombu/kombu_listener.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mistral/engine/rpc_backend/kombu/kombu_listener.py b/mistral/engine/rpc_backend/kombu/kombu_listener.py index 54908992a..a13be29ce 100644 --- a/mistral/engine/rpc_backend/kombu/kombu_listener.py +++ b/mistral/engine/rpc_backend/kombu/kombu_listener.py @@ -32,7 +32,7 @@ class KombuRPCListener(ConsumerMixin): self._connections = itertools.cycle(connections) self._callback_queue = callback_queue self._thread = None - self.connection = self._connections.next() + self.connection = six.next(self._connections) # TODO(ddeja): Those 2 options should be gathered from config. self._sleep_time = 1