Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- diff --git a/zaqar/bench/config.py b/zaqar/bench/config.py
- index b3a476d..7b22cea 100644
- --- a/zaqar/bench/config.py
- +++ b/zaqar/bench/config.py
- @@ -70,4 +70,4 @@ _CLI_OPTIONS = (
- help=('Do not reset queues before running'
- 'the performance test')),
- )
- -conf.register_cli_opts(_CLI_OPTIONS)
- +# conf.register_cli_opts(_CLI_OPTIONS)
- diff --git a/zaqar/common/configs.py b/zaqar/common/configs.py
- index af49b0a..7e1eb34 100644
- --- a/zaqar/common/configs.py
- +++ b/zaqar/common/configs.py
- @@ -68,3 +68,10 @@ def _config_options():
- (_DRIVER_GROUP, _DRIVER_OPTIONS),
- (_SIGNED_URL_GROUP, _SIGNED_URL_OPTIONS),
- (_NOTIFICATION_GROUP, _NOTIFICATION_OPTIONS)]
- +
- +for group, options in _config_options():
- + for opt in options:
- + try:
- + cfg.CONF.register_opt(opt, group=group)
- + except cfg.DuplicateOptError:
- + pass
- \ No newline at end of file
- diff --git a/zaqar/storage/mongodb/options.py b/zaqar/storage/mongodb/options.py
- index 627d9b5..8f9063d 100644
- --- a/zaqar/storage/mongodb/options.py
- +++ b/zaqar/storage/mongodb/options.py
- @@ -145,3 +145,10 @@ def _config_options():
- """
- return [(MANAGEMENT_MONGODB_GROUP, MANAGEMENT_MONGODB_OPTIONS),
- (MESSAGE_MONGODB_GROUP, MESSAGE_MONGODB_OPTIONS)]
- +
- +for group, options in _config_options():
- + for opt in options:
- + try:
- + cfg.CONF.register_opt(opt, group=group)
- + except cfg.DuplicateOptError:
- + pass
- \ No newline at end of file
- diff --git a/zaqar/storage/pipeline.py b/zaqar/storage/pipeline.py
- index d7df0fa..70110da 100644
- --- a/zaqar/storage/pipeline.py
- +++ b/zaqar/storage/pipeline.py
- @@ -41,6 +41,13 @@ _PIPELINE_GROUP = 'storage'
- def _config_options():
- return [(_PIPELINE_GROUP, _PIPELINE_CONFIGS)]
- +for group, options in _config_options():
- + for opt in options:
- + try:
- + cfg.CONF.register_opt(opt, group=group)
- + except cfg.DuplicateOptError:
- + pass
- +
- def _get_storage_pipeline(resource_name, conf, *args, **kwargs):
- """Constructs and returns a storage resource pipeline.
- diff --git a/zaqar/storage/pooling.py b/zaqar/storage/pooling.py
- index b53f05c..2456690 100644
- --- a/zaqar/storage/pooling.py
- +++ b/zaqar/storage/pooling.py
- @@ -52,6 +52,12 @@ _POOL_CACHE_TTL = 10
- def _config_options():
- return [(_CATALOG_GROUP, _CATALOG_OPTIONS)]
- +for group, options in _config_options():
- + for opt in options:
- + try:
- + cfg.CONF.register_opt(opt, group=group)
- + except cfg.DuplicateOptError:
- + pass
- def _pool_cache_key(queue, project=None):
- # NOTE(kgriffs): Use string concatenation for performance,
- diff --git a/zaqar/storage/redis/options.py b/zaqar/storage/redis/options.py
- index fff9908..93a1ccf 100644
- --- a/zaqar/storage/redis/options.py
- +++ b/zaqar/storage/redis/options.py
- @@ -69,3 +69,10 @@ MESSAGE_REDIS_GROUP = 'drivers:message_store:redis'
- def _config_options():
- return [(MANAGEMENT_REDIS_GROUP, MANAGEMENT_REDIS_OPTIONS),
- (MESSAGE_REDIS_GROUP, MESSAGE_REDIS_OPTIONS)]
- +
- +for group, options in _config_options():
- + for opt in options:
- + try:
- + cfg.CONF.register_opt(opt, group=group)
- + except cfg.DuplicateOptError:
- + pass
- \ No newline at end of file
- diff --git a/zaqar/storage/sqlalchemy/options.py b/zaqar/storage/sqlalchemy/options.py
- index 55603d9..4d31aeb 100644
- --- a/zaqar/storage/sqlalchemy/options.py
- +++ b/zaqar/storage/sqlalchemy/options.py
- @@ -32,3 +32,10 @@ MANAGEMENT_SQLALCHEMY_GROUP = 'drivers:management_store:sqlalchemy'
- def _config_options():
- return [(MANAGEMENT_SQLALCHEMY_GROUP, MANAGEMENT_SQLALCHEMY_OPTIONS)]
- +
- +for group, options in _config_options():
- + for opt in options:
- + try:
- + cfg.CONF.register_opt(opt, group=group)
- + except cfg.DuplicateOptError:
- + pass
- \ No newline at end of file
- diff --git a/zaqar/transport/base.py b/zaqar/transport/base.py
- index 8c847fa..38be9b8 100644
- --- a/zaqar/transport/base.py
- +++ b/zaqar/transport/base.py
- @@ -45,6 +45,13 @@ def _config_options():
- (_TRANSPORT_GROUP, _RESOURCE_DEFAULTS),
- ]
- +for group, options in _config_options():
- + for opt in options:
- + try:
- + cfg.CONF.register_opt(opt, group=group)
- + except cfg.DuplicateOptError:
- + pass
- +
- class ResourceDefaults(object):
- """Registers and exposes defaults for resource fields."""
- diff --git a/zaqar/transport/validation.py b/zaqar/transport/validation.py
- index 40cfc68..3b8ef75 100644
- --- a/zaqar/transport/validation.py
- +++ b/zaqar/transport/validation.py
- @@ -88,6 +88,13 @@ PROJECT_ID_MAX_LEN = 256
- def _config_options():
- return [(_TRANSPORT_LIMITS_GROUP, _TRANSPORT_LIMITS_OPTIONS)]
- +for group, options in _config_options():
- + for opt in options:
- + try:
- + cfg.CONF.register_opt(opt, group=group)
- + except cfg.DuplicateOptError:
- + pass
- +
- class ValidationFailed(ValueError):
- """User input did not follow API restrictions."""
- diff --git a/zaqar/transport/websocket/driver.py b/zaqar/transport/websocket/driver.py
- index 1838d24..96807fa 100644
- --- a/zaqar/transport/websocket/driver.py
- +++ b/zaqar/transport/websocket/driver.py
- @@ -50,6 +50,13 @@ LOG = logging.getLogger(__name__)
- def _config_options():
- return [(_WS_GROUP, _WS_OPTIONS)]
- +for group, options in _config_options():
- + for opt in options:
- + try:
- + cfg.CONF.register_opt(opt, group=group)
- + except cfg.DuplicateOptError:
- + pass
- +
- class Driver(base.DriverBase):
- diff --git a/zaqar/transport/wsgi/driver.py b/zaqar/transport/wsgi/driver.py
- index aa7575f..c734b3c 100644
- --- a/zaqar/transport/wsgi/driver.py
- +++ b/zaqar/transport/wsgi/driver.py
- @@ -48,6 +48,13 @@ LOG = logging.getLogger(__name__)
- def _config_options():
- return [(_WSGI_GROUP, _WSGI_OPTIONS)]
- +for group, options in _config_options():
- + for opt in options:
- + try:
- + cfg.CONF.register_opt(opt, group=group)
- + except cfg.DuplicateOptError:
- + pass
- +
- class Driver(transport.DriverBase):
Add Comment
Please, Sign In to add comment