From 0be0ab77a96587f278bb9089255f39dc203dfb20 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?St=C3=A9phane=20Brunner?= Date: Wed, 31 Mar 2021 16:44:05 +0200 Subject: [PATCH] Add message to debug pendings --- tilecloud/store/redis.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/tilecloud/store/redis.py b/tilecloud/store/redis.py index 5a791a381..79b3c2a1f 100644 --- a/tilecloud/store/redis.py +++ b/tilecloud/store/redis.py @@ -85,6 +85,7 @@ def list(self): count=1, block=round(self._timeout_ms), ) + logger.debug("Get %d new elements", len(queues)) if not queues: queues = self._claim_olds() @@ -146,15 +147,20 @@ def delete_all(self): self._master.xtrim(name=self._errors_name, maxlen=0) def _claim_olds(self): + logger.debug("Claim old's") pendings = self._master.xpending_range( name=self._name, groupname=STREAM_GROUP, min="-", max="+", count=10 ) if not pendings: + logger.debug("Empty pendings") # None means there is nothing pending at all return None to_steal = [] to_drop = [] for pending in pendings: + logger.debug( + "Pending for %d, threshold %d", int(pending["time_since_delivered"]), self._pending_timeout_ms + ) if int(pending["time_since_delivered"]) >= self._pending_timeout_ms: id_ = pending["message_id"] nb_retries = int(pending["times_delivered"]) @@ -172,6 +178,7 @@ def _claim_olds(self): ) to_drop.append(id_) + logger.debug("%d elements to drop", len(to_drop)) if to_drop: drop_messages = self._master.xclaim( name=self._name, @@ -192,6 +199,7 @@ def _claim_olds(self): ) stats.increment_counter(["redis", self._name_str, "dropped"], len(to_drop)) + logger.debug("%d elements to steal", len(to_steal)) if to_steal: messages = self._master.xclaim( name=self._name,