From 28060d9d3d6491acebe84024bdfed4f9cd1340f0 Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Wed, 14 Feb 2024 21:10:36 -0700
Subject: [PATCH] add chronicles

---
 src/apatheia/jobs.nim | 10 +++++++---
 tests/tjobs.nim       |  1 +
 2 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/src/apatheia/jobs.nim b/src/apatheia/jobs.nim
index cf09588..6c93a06 100644
--- a/src/apatheia/jobs.nim
+++ b/src/apatheia/jobs.nim
@@ -6,9 +6,14 @@ import ./queues
 
 import taskpools
 import chronos
+import chronicles
 
 export queues
 
+logScope:
+  # Lexical properties are typically assigned to a constant:
+  topics = "apatheia jobs"
+
 ## This module provides a simple way to submit jobs to taskpools
 ## and getting a result returned via an async future.
 ## 
@@ -36,10 +41,9 @@ proc processJobs*[T](jobs: JobQueue[T]) {.async.} =
   ## and complete the associated futures.
 
   while jobs.running:
-    echo "jobs running..."
+    info "Processing jobs in job queue"
     let res = await(jobs.queue.wait()).get()
-    echo "jobs result: ", res.repr
-    echo "jobs futes: ", jobs.futures.unsafeAddr.pointer.repr, " => ", jobs.futures.keys().toSeq()
+    debug "got job result", jobResult = res
     let (id, ret) = res
     var fut: Future[T]
     if jobs.futures.pop(id, fut):
diff --git a/tests/tjobs.nim b/tests/tjobs.nim
index 8888d8e..8d186c3 100644
--- a/tests/tjobs.nim
+++ b/tests/tjobs.nim
@@ -1,5 +1,6 @@
 import std/os
 
+import chronicles
 import chronos
 import chronos/threadsync
 import chronos/unittest2/asynctests