From 2eaa34552c42374ec48e3c41c84a1e7a74be13eb Mon Sep 17 00:00:00 2001
From: Assaf Giladi <assaf@weka.io>
Date: Wed, 2 Oct 2019 19:24:31 +0300
Subject: [PATCH] add necessary logs

---
 talker/client.py  | 4 ++++
 talker/command.py | 1 +
 talker/reactor.py | 2 ++
 3 files changed, 7 insertions(+)

diff --git a/talker/client.py b/talker/client.py
index 4a14b80..4a5176d 100644
--- a/talker/client.py
+++ b/talker/client.py
@@ -68,6 +68,10 @@ def redis_params(self):
             port=int(self._port)
         )
 
+    @property
+    def name(self):
+        return self._name
+
     @cached_property
     def redis(self):
         """
diff --git a/talker/command.py b/talker/command.py
index cdb59f4..d6e5588 100644
--- a/talker/command.py
+++ b/talker/command.py
@@ -474,6 +474,7 @@ def check_client_timeout(self):
                 exception_cls = TalkerCommandLost if talker_alive else TalkerServerTimeout
                 self.raise_exception(exception_cls=exception_cls, timeout=self.ack_timer.elapsed)
         elif self.client_timer.expired:
+            _verbose_logger.debug("Client command timeout (%s)", self)
             self.raise_exception(
                 exception_cls=ClientCommandTimeoutError, timeout=self.ack_timer.elapsed, started=self.since_started
             )
diff --git a/talker/reactor.py b/talker/reactor.py
index 3d28623..7353ca1 100644
--- a/talker/reactor.py
+++ b/talker/reactor.py
@@ -62,6 +62,8 @@ def _send_data(self, items):
                 for item in items:
                     redis_func = getattr(pipeline, item.cmd)
                     redis_func(*item.args, **item.kwargs)
+                _verbose_logger.debug(
+                    'Executing talker %s redis %s pipeline', self.talker.name, self.talker.redis_params['host'])
                 results = pipeline.execute()
                 assert len(results) == len(items), "Our redis pipeline got out of sync?"
                 self._log_sent_items(items)  # logs to debug WEKAPP-35305