openstack/cloudkitty
Code Issues Proposed changes

Fixed collector unhandled exception management

Browse Source 
Change-Id: I558168a2ac29e8252d8f12b78777391739942855
This commit is contained in:
Stéphane Albert 2015-05-11 17:36:08 +02:00
parent f072724991
commit 2af754d424
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
cloudkitty/orchestrator.py
View File

@ -178,17 +178,21 @@ class Worker(BaseWorker):
for service in CONF.collect.services:
try:
data = self._collect(service, timestamp)
try:
data = self._collect(service, timestamp)
except collector.NoDataCollected:
raise
except Exception as e:
LOG.warn('Error while collecting service {service}:'
' {error}'.format(service=service,
error=str(e)))
raise collector.NoDataCollected('', service)
except collector.NoDataCollected:
begin = timestamp
end = begin + self._period
for processor in self._processors:
processor.obj.nodata(begin, end)
self._storage.nodata(begin, end, self._tenant_id)
except Exception as e:
LOG.warn('Error while collecting service {service}:'
' {error}'.format(service=service,
error=str(e)))
else:
# Rating
for processor in self._processors: