The redis_queue parameter is not necessarily defined on the app config

This commit is contained in:
Fabio Manganiello 2021-03-10 11:14:56 +01:00
parent 775478fff0
commit 211025cedb
1 changed files with 1 additions and 1 deletions

View File

@ -23,7 +23,7 @@ _logger = None
def bus():
global _bus
if _bus is None:
_bus = RedisBus(redis_queue=current_app.config['redis_queue'])
_bus = RedisBus(redis_queue=current_app.config.get('redis_queue'))
return _bus