core.job: log variants from the suite.variants

Now variants is for each Test Suite, we should log from there. Also
jobdata.record only needs the job object pointer.
Signed-off-by: NBeraldo Leal <bleal@redhat.com>
上级 69f9a009
......@@ -247,7 +247,7 @@ class Job:
LOG_JOB.info("Command line: %s", cmdline)
LOG_JOB.info('')
def _log_job_debug_info(self, variants):
def _log_job_debug_info(self):
"""
Log relevant debug information to the job log.
"""
......@@ -255,7 +255,8 @@ class Job:
self._log_avocado_version()
self._log_avocado_config()
self._log_avocado_datadir()
self._log_variants(variants)
for suite in self.test_suites:
self._log_variants(suite.variants)
self._log_tmp_dir()
self._log_job_id()
......@@ -547,11 +548,8 @@ class Job:
"""
The actual test execution phase
"""
self._log_job_debug_info(self.test_suite.variants)
jobdata.record(self.config,
self.logdir,
self.test_suite.variants,
sys.argv)
self._log_job_debug_info()
jobdata.record(self, sys.argv)
if not self.test_suites:
self.exitcode |= exit_codes.AVOCADO_JOB_FAIL
......
......@@ -33,7 +33,7 @@ JOB_CONFIG_FILENAME = 'args.json'
CMDLINE_FILENAME = 'cmdline'
def record(config, logdir, variants, cmdline=None):
def record(job, cmdline=None):
"""
Records all required job information.
"""
......@@ -41,7 +41,7 @@ def record(config, logdir, variants, cmdline=None):
for log in [LOG_UI, LOG_JOB]:
log.warning("jobdata.variants: Unable to serialize '%s'", item)
return str(item)
base_dir = init_dir(logdir, JOB_DATA_DIR)
base_dir = init_dir(job.logdir, JOB_DATA_DIR)
path_cfg = os.path.join(base_dir, CONFIG_FILENAME)
path_references = os.path.join(base_dir, TEST_REFERENCES_FILENAME)
path_variants = os.path.join(base_dir, VARIANTS_FILENAME)
......@@ -49,7 +49,7 @@ def record(config, logdir, variants, cmdline=None):
path_job_config = os.path.join(base_dir, JOB_CONFIG_FILENAME)
path_cmdline = os.path.join(base_dir, CMDLINE_FILENAME)
references = config.get('run.references')
references = job.config.get('run.references')
if references:
with open(path_references, 'w') as references_file:
references_file.write('%s' % references)
......@@ -62,7 +62,10 @@ def record(config, logdir, variants, cmdline=None):
os.fsync(config_file)
with open(path_variants, 'w') as variants_file:
json.dump(variants.dump(), variants_file, default=json_bad_variants_obj)
variants = []
for suite in job.test_suites:
variants.append(suite.variants.dump())
json.dump(variants, variants_file, default=json_bad_variants_obj)
variants_file.flush()
os.fsync(variants_file)
......@@ -72,7 +75,7 @@ def record(config, logdir, variants, cmdline=None):
os.fsync(pwd_file)
with open(path_job_config, 'w') as job_config_file:
json.dump(config, job_config_file, default=lambda x: None)
json.dump(job.config, job_config_file, default=lambda x: None)
job_config_file.flush()
os.fsync(job_config_file)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册