diff --git a/swift/obj/updater.py b/swift/obj/updater.py index e48866d798..2500e73df3 100644 --- a/swift/obj/updater.py +++ b/swift/obj/updater.py @@ -427,7 +427,8 @@ class ObjectUpdater(Daemon): self.interval = float(conf.get('interval', 300)) self.container_ring = None self.concurrency = int(conf.get('concurrency', 8)) - self.updater_workers = int(conf.get('updater_workers', 1)) + self.updater_workers = config_positive_int_value( + conf.get('updater_workers', 1)) if 'slowdown' in conf: self.logger.warning( 'The slowdown option is deprecated in favor of ' diff --git a/test/unit/obj/test_updater.py b/test/unit/obj/test_updater.py index 6fc2b6b3ce..bb5a98db0d 100644 --- a/test/unit/obj/test_updater.py +++ b/test/unit/obj/test_updater.py @@ -185,6 +185,8 @@ class TestObjectUpdater(unittest.TestCase): check_bad({'interval': 'foo'}) check_bad({'concurrency': 'bar'}) check_bad({'concurrency': '1.0'}) + check_bad({'updater_workers': '0'}) + check_bad({'updater_workers': '-1'}) check_bad({'slowdown': 'baz'}) check_bad({'objects_per_second': 'quux'}) check_bad({'max_objects_per_container_per_second': '-0.1'})