notifs / staging: and the moksha fix

Signed-off-by: Kevin Fenzi <kevin@scrye.com>
This commit is contained in:
Kevin Fenzi 2022-09-28 17:12:13 -07:00
parent 0ab09960c4
commit b74ec6505c

View file

@ -69,7 +69,7 @@ class Consumer(object):
for topic in iterate(self.topic):
log.debug('Subscribing to consumer topic %s' % topic)
self.hub.subscribe(topic, callback)
self.hub.subscribe(topic.decode("utf-8"), callback)
# If the consumer specifies an 'app', then setup `self.engine` to
# be a SQLAlchemy engine, along with a configured DBSession