]> git-server-git.apps.pok.os.sepia.ceph.com Git - teuthology.git/commitdiff
Store job.jid as job_id
authorZack Cerza <zack@redhat.com>
Thu, 19 May 2016 16:09:14 +0000 (10:09 -0600)
committerZack Cerza <zack@redhat.com>
Tue, 24 May 2016 15:34:00 +0000 (09:34 -0600)
This is a trivial commit to prepare for a refactor

Signed-off-by: Zack Cerza <zack@redhat.com>
teuthology/worker.py

index fe12aed0f7c22e53b568c13fb99b6a1038d7fcfd..b390b36e79fabfdf2a98fd021885cdabea109bbe 100644 (file)
@@ -101,18 +101,19 @@ def main(ctx):
 
         # bury the job so it won't be re-run if it fails
         job.bury()
-        log.info('Reserved job %d', job.jid)
+        job_id = job.jid
+        log.info('Reserved job %d', job_id)
         log.info('Config is: %s', job.body)
         job_config = yaml.safe_load(job.body)
+        job_config['job_id'] = str(job_id)
 
         if job_config.get('stop_worker'):
             keep_running = False
 
-        job_config['job_id'] = str(job.jid)
         safe_archive = safepath.munge(job_config['name'])
         job_config['worker_log'] = log_file_path
         archive_path_full = os.path.join(
-            ctx.archive_dir, safe_archive, str(job.jid))
+            ctx.archive_dir, safe_archive, str(job_id))
         job_config['archive_path'] = archive_path_full
 
         # If the teuthology branch was not specified, default to master and
@@ -169,7 +170,7 @@ def main(ctx):
         else:
             log.info('Creating archive dir %s', archive_path_full)
             safepath.makedirs(ctx.archive_dir, safe_archive)
-            log.info('Running job %d', job.jid)
+            log.info('Running job %d', job_id)
             run_job(job_config, teuth_bin_path, ctx.verbose)
         job.delete()