log = logging.getLogger(__name__)
-
-def do_download(ctx, config):
+@contextlib.contextmanager
+def download(ctx, config):
assert isinstance(config, dict)
log.info('Downloading s3-tests...')
testdir = teuthology.get_testdir(ctx)
],
)
-@contextlib.contextmanager
-def download(ctx, config):
- return do_download(ctx, config)
def _config_user(s3tests_conf, section, user):
s3tests_conf[section].setdefault('user_id', user)
s3tests_conf[section].setdefault('access_key', ''.join(random.choice(string.uppercase) for i in xrange(20)))
s3tests_conf[section].setdefault('secret_key', base64.b64encode(os.urandom(40)))
-def do_create_users(ctx, config):
+
+@contextlib.contextmanager
+def create_users(ctx, config):
assert isinstance(config, dict)
log.info('Creating rgw users...')
testdir = teuthology.get_testdir(ctx)
],
)
-@contextlib.contextmanager
-def create_users(ctx, config):
- return do_create_users(ctx, config)
-def do_configure(ctx, config):
+@contextlib.contextmanager
+def configure(ctx, config):
assert isinstance(config, dict)
log.info('Configuring s3-tests...')
testdir = teuthology.get_testdir(ctx)
yield
@contextlib.contextmanager
-def configure(ctx, config):
- return do_configure(ctx, config)
-
-def do_run_tests(ctx, config):
+def run_tests(ctx, config):
assert isinstance(config, dict)
testdir = teuthology.get_testdir(ctx)
for client, client_config in config.iteritems():
ctx.cluster.only(client).run(
args=args,
)
-
-@contextlib.contextmanager
-def run_tests(ctx, config):
- do_run_tests(ctx, config)
yield
@contextlib.contextmanager