def run(self): bucket = self.distribution.get_command_obj('create_bucket_types') bucket.riak_admin = self.riak_admin for cmd_name in self.get_sub_commands(): self.run_command(cmd_name)