From 331ac315511b218123ba6037678908d4b4ca9def Mon Sep 17 00:00:00 2001
From: Deklan Dieterly <deklan.dieterly@hp.com>
Date: Mon, 8 Dec 2014 08:39:33 -0700
Subject: [PATCH] Add logging at info level when persister is waiting to
 acquire locks

Change-Id: Ia889f518df3f1ada15819cd7c82dfcd57555e1b4
---
 monasca_persister/persister.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/monasca_persister/persister.py b/monasca_persister/persister.py
index ca021e13..ccf65c79 100644
--- a/monasca_persister/persister.py
+++ b/monasca_persister/persister.py
@@ -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: