fix flask_nameko bug 2

This commit is contained in:
BryantHe 2023-06-01 04:21:20 +08:00
parent 121cc2e30b
commit 3c56d3766b
1 changed files with 1 additions and 1 deletions

View File

@ -22,7 +22,7 @@ class PooledClusterRpcProxy(object):
self.configure(config) self.configure(config)
def configure(self, config): def configure(self, config):
if not config.get('AMQP_URI'): if not config.get('uri'):
raise BadConfigurationError( raise BadConfigurationError(
"Please provide a valid configuration.") "Please provide a valid configuration.")