jobs=len(jobs),
))
if jobs:
- status, msg, content = self.create_run(run_name)
- if status == 200:
- self.report_jobs(run_name, jobs.keys())
- elif msg.endswith('already exists'):
- if self.refresh:
- self.report_jobs(run_name, jobs.keys())
- else:
+ if not self.refresh:
+ status, msg, content = self.create_run(run_name)
+ if status != 200:
log.info(" already present; skipped")
+ return
+ self.report_jobs(run_name, jobs.keys())
elif not jobs:
log.debug(" no jobs; skipped")
return len(jobs)
try:
log.info("Pushing job info to %s", config.results_server)
- create_run(run_name)
push_job_info(run_name, job_id, job_info)
except RequestFailedError:
log.exception("Could not report results to %s" %