changed to only post process if successful
This commit is contained in:
parent
54a1f5fb0e
commit
b815516b5f
@ -366,6 +366,9 @@ def process_raw_data(deployment, args, json_args):
|
||||
STACKDB.save(record)
|
||||
return record
|
||||
|
||||
def post_process(raw, body):
|
||||
aggregate_lifecycle(raw)
|
||||
aggregate_usage(raw, body)
|
||||
|
||||
def _post_process_raw_data(rows, highlight=None):
|
||||
for row in rows:
|
||||
|
@ -92,9 +92,7 @@ class NovaConsumer(kombu.mixins.ConsumerMixin):
|
||||
if raw:
|
||||
self.processed += 1
|
||||
message.ack()
|
||||
|
||||
views.aggregate_lifecycle(raw)
|
||||
views.aggregate_usage(raw, args[1])
|
||||
views.post_process(raw, args[1])
|
||||
|
||||
self._check_memory()
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user