self.base_uri = base_uri or config.results_server
if self.base_uri:
self.base_uri = self.base_uri.rstrip('/')
+
self.serializer = ResultsSerializer(archive_base, log=self.log)
self.save_last_run = save
self.refresh = refresh
self.session = self._make_session()
+ if not self.base_uri:
+ msg = "No results_server set in {yaml}; cannot report results"
+ log.warn(msg.format(yaml=config.teuthology_yaml))
+
def _make_session(self, max_retries=10):
session = requests.Session()
adapter = requests.adapters.HTTPAdapter(max_retries=max_retries)
ResultsReporter will ask teuthology.config.
"""
reporter = ResultsReporter()
+ if not reporter.base_uri:
+ return
reporter.report_job(run_name, job_id, job_info)
"""
log = init_logging()
- if not config.results_server:
- msg = "No results_server set in {yaml}; not attempting to push results"
- log.debug(msg.format(yaml=config.teuthology_yaml))
- return
- elif job_config.get('job_id') is None:
+ if job_config.get('job_id') is None:
log.warning('No job_id found; not reporting results')
return
"""
log = init_logging()
- if not config.results_server:
- msg = "No results_server set in {yaml}; not attempting to delete job"
- log.debug(msg.format(yaml=config.teuthology_yaml))
- return
-
if isinstance(job_ids, int):
job_ids = [str(job_ids)]
elif isinstance(job_ids, basestring):
job_ids = [job_ids]
reporter = ResultsReporter()
+ if not reporter.base_uri:
+ return
log.debug("Deleting jobs from {server}: {jobs}".format(
server=config.results_server, jobs=str(job_ids)))