diff --git a/tasks/divergent_priors2.py b/tasks/divergent_priors2.py index 0fc9a2f8d77..78d6043a536 100644 --- a/tasks/divergent_priors2.py +++ b/tasks/divergent_priors2.py @@ -177,6 +177,7 @@ def task(ctx, config): log.info("reviving divergent %d", divergent) ctx.manager.revive_osd(divergent) ctx.manager.wait_run_admin_socket('osd', divergent, ['dump_ops_in_flight']) + time.sleep(20); log.info('allowing recovery') # Set osd_recovery_delay_start back to 0 and kick the queue diff --git a/tasks/radosbench.py b/tasks/radosbench.py index 0924dab5295..bb1b8252403 100644 --- a/tasks/radosbench.py +++ b/tasks/radosbench.py @@ -46,6 +46,7 @@ def task(ctx, config): testdir = teuthology.get_testdir(ctx) + create_pool = config.get('create_pool', True) for role in config.get('clients', ['client.0']): assert isinstance(role, basestring) PREFIX = 'client.' @@ -63,12 +64,11 @@ def task(ctx, config): cleanup = [] if not config.get('cleanup', True): cleanup = ['--no-cleanup'] - pool = 'data' - if config.get('create_pool', True): - if config.get('pool'): - pool = config.get('pool') - if pool != 'data': - ctx.manager.create_pool(pool, erasure_code_profile_name=profile_name) + + pool = config.get('pool', 'data') + if create_pool: + if pool != 'data': + ctx.manager.create_pool(pool, erasure_code_profile_name=profile_name) else: pool = ctx.manager.create_pool_with_unique_name(erasure_code_profile_name=profile_name) @@ -99,5 +99,5 @@ def task(ctx, config): log.info('joining radosbench (timing out after %ss)', timeout) run.wait(radosbench.itervalues(), timeout=timeout) - if pool is not 'data': + if pool is not 'data' and create_pool: ctx.manager.remove_pool(pool) diff --git a/tasks/radosgw_admin.py b/tasks/radosgw_admin.py index b6baa4cd4e5..7cea724ae23 100644 --- a/tasks/radosgw_admin.py +++ b/tasks/radosgw_admin.py @@ -781,7 +781,7 @@ def task(ctx, config): for obj in out: # TESTCASE 'log-show','log','show','after activity','returns expected info' - if obj[:4] == 'meta' or obj[:4] == 'data': + if obj[:4] == 'meta' or obj[:4] == 'data' or obj[:18] == 'obj_delete_at_hint': continue (err, rgwlog) = rgwadmin(ctx, client, ['log', 'show', '--object', obj],