fix flask_nameko bug 4

This commit is contained in:
BryantHe 2023-06-01 04:39:35 +08:00
parent 81de5dcd60
commit bc3619a83b
1 changed files with 1 additions and 2 deletions

View File

@ -69,8 +69,7 @@ class FlaskPooledClusterRpcProxy(PooledClusterRpcProxy):
def init_app(self, app): def init_app(self, app):
config = dict() config = dict()
for key, val in app.config.items(): for key, val in app.config.items():
match = re.match(r"NAMEKO\_(?P<name>.*)", key) if key == 'NAMEKO_AMQP_URI':
if match:
config['uri'] = val config['uri'] = val
self.configure(config) self.configure(config)