openstack/monasca-persister
Code Issues Proposed changes

Add logging at info level when persister is waiting to acquire locks

Browse Source 
Change-Id: Ia889f518df3f1ada15819cd7c82dfcd57555e1b4
This commit is contained in:
Deklan Dieterly 2014-12-08 08:39:33 -07:00
parent f4231d41f4
commit 331ac31551
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
monasca_persister/persister.py
View File

@ -226,7 +226,7 @@ class AbstractPersister(threading.Thread):
if self._json_body:
self._influxdb_client.write_points(self._json_body)
self._consumer.commit(partitions=partitions)
LOG.info("processed {} messages from topic '{}'".format(
LOG.info("Processed {} messages from topic '{}'".format(
len(self._json_body), self._kafka_topic))
self._json_body = []
self._last_flush = datetime.now()
@ -342,6 +342,8 @@ class AbstractPersister(threading.Thread):
elif set_partitioner.allocating:
LOG.info("Waiting to acquire locks on partition set")
set_partitioner.wait_for_acquire()
except: