diff --git a/hexus/writer.py b/hexus/writer.py index 71d7c02..e36e450 100644 --- a/hexus/writer.py +++ b/hexus/writer.py @@ -107,6 +107,12 @@ def enqueue( ) try: self._queue.put_nowait(item) + logger.debug( + "hexus queue: enqueued write action=%s, agent=%s, target=%s", + action, + agent_identity, + target, + ) return True except queue.Full: with self._lock: @@ -179,6 +185,13 @@ def _run(self) -> None: t0 = time.perf_counter() self._worker_fn(item) duration = time.perf_counter() - t0 + logger.debug( + "hexus queue: processed write action=%s, agent=%s, target=%s in %.4fs", + item.action, + item.agent_identity, + item.target, + duration, + ) with self._lock: self._latencies.append(duration) if len(self._latencies) > 1000: