From: Zack Cerza Date: Wed, 16 Apr 2014 14:35:04 +0000 (-0500) Subject: Generate subtasks instead of copy/pasting them X-Git-Tag: 1.1.0~1537 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F241%2Fhead;p=teuthology.git Generate subtasks instead of copy/pasting them Signed-off-by: Zack Cerza --- diff --git a/teuthology/task/rgw.py b/teuthology/task/rgw.py index ebff51a4e..6f6064cdd 100644 --- a/teuthology/task/rgw.py +++ b/teuthology/task/rgw.py @@ -762,47 +762,37 @@ def task(ctx, config): if 'frontend' in config: ctx.rgw.frontend = config['frontend'] del config['frontend'] - log.info("Using %s as radosgw frontend", ctx.rgw.frontend) + subtasks = [ + lambda: configure_regions_and_zones( + ctx=ctx, + config=config, + regions=regions, + role_endpoints=role_endpoints, + ), + lambda: configure_users( + ctx=ctx, + config=config, + everywhere=bool(regions), + ), + lambda: create_nonregion_pools( + ctx=ctx, config=config, regions=regions), + ] if ctx.rgw.frontend == 'apache': - with contextutil.nested( - lambda: create_apache_dirs(ctx=ctx, config=config), - lambda: configure_regions_and_zones( - ctx=ctx, - config=config, - regions=regions, - role_endpoints=role_endpoints, - ), - lambda: configure_users( - ctx=ctx, - config=config, - everywhere=bool(regions), - ), - lambda: create_nonregion_pools( - ctx=ctx, config=config, regions=regions), + subtasks.insert(0, lambda: create_apache_dirs(ctx=ctx, config=config)) + subtasks.extend([ lambda: ship_apache_configs(ctx=ctx, config=config, role_endpoints=role_endpoints), lambda: start_rgw(ctx=ctx, config=config), lambda: start_apache(ctx=ctx, config=config), - ): - yield + ]) elif ctx.rgw.frontend == 'civetweb': - with contextutil.nested( - lambda: configure_regions_and_zones( - ctx=ctx, - config=config, - regions=regions, - role_endpoints=role_endpoints, - ), - lambda: configure_users( - ctx=ctx, - config=config, - everywhere=bool(regions), - ), - lambda: create_nonregion_pools( - ctx=ctx, config=config, regions=regions), + subtasks.extend([ lambda: start_rgw(ctx=ctx, config=config), - ): - yield + ]) else: raise ValueError("frontend must be 'apache' or 'civetweb'") + + log.info("Using %s as radosgw frontend", ctx.rgw.frontend) + with contextutil.nested(*subtasks): + yield