Merge "Create state entry for tenant_id in _dispatch for hybrid storage"

This commit is contained in:
Zuul 2018-01-31 14:38:32 +00:00 committed by Gerrit Code Review
commit 3ae0e9b780
1 changed files with 3 additions and 1 deletions

View File

@ -85,7 +85,7 @@ class HybridStorage(storage.BaseStorage):
r = q.first()
do_commit = False
if r:
if state >= r.state:
if state > r.state:
q.update({'state': state})
do_commit = True
else:
@ -113,6 +113,8 @@ class HybridStorage(storage.BaseStorage):
service=service, groupby=groupby)
def _dispatch(self, data, tenant_id):
if not self.get_state(tenant_id):
self._set_state(tenant_id, self.usage_start_dt.get(tenant_id))
for service in data:
for frame in data[service]:
self._hybrid_backend.append_time_frame(