WAIT_PAUSE = 5 * 60
__slots__ = (
'args', 'name', 'base_config', 'suite_repo_path', 'base_yaml_paths',
- 'base_args', 'package_versions',
+ 'base_args', 'package_versions', 'kernel_dict', 'config_input',
)
def __init__(self, args):
:returns: A JobConfig object
"""
- kernel_dict = self.choose_kernel()
+ self.kernel_dict = self.choose_kernel()
ceph_hash = self.choose_ceph_hash()
# We don't store ceph_version because we don't use it yet outside of
# logging.
suite_branch = self.choose_suite_branch()
suite_hash = self.choose_suite_hash(suite_branch)
- config_input = dict(
+ self.config_input = dict(
suite=self.args.suite,
suite_branch=suite_branch,
suite_hash=suite_hash,
archive_upload=config.archive_upload,
archive_upload_key=config.archive_upload_key,
)
- conf_dict = substitute_placeholders(dict_templ, config_input)
- conf_dict.update(kernel_dict)
- job_config = JobConfig.from_dict(conf_dict)
- return job_config
+ return self.build_base_config()
def choose_kernel(self):
# Put together a stanza specifying the kernel hash
util.schedule_fail(message=str(exc), name=self.name)
log.info("ceph-qa-suite branch: %s %s", suite_branch, suite_hash)
+ def build_base_config(self):
+ conf_dict = substitute_placeholders(dict_templ, self.config_input)
+ conf_dict.update(self.kernel_dict)
+ job_config = JobConfig.from_dict(conf_dict)
+ return job_config
+
def build_base_args(self):
base_args = [
'--name', self.name,
if results_url:
log.info("Test results viewable at %s", results_url)
-
def collect_jobs(self, arch, configs, newest=False):
jobs_to_schedule = []
jobs_missing_packages = []