From 29babc26000fb46a70267dade5ff52a3d0254013 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Wed, 14 Feb 2024 21:54:53 -0700 Subject: [PATCH] logging --- src/apatheia/jobs.nim | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/apatheia/jobs.nim b/src/apatheia/jobs.nim index 23675a7..f0b47a9 100644 --- a/src/apatheia/jobs.nim +++ b/src/apatheia/jobs.nim @@ -52,13 +52,13 @@ proc processJobs*[T](jobs: JobQueue[T]) {.async.} = fut.complete(ret) else: raise newException(IndexDefect, "missing future: " & $id) - info "Processing jobs in job queue" + info "Finishing processing jobs for type ", type=tn proc createFuture*[T](jobs: JobQueue[T], name: static string): (JobResult[T], Future[T]) = let fut = newFuture[T](name) let id = JobId fut.id() jobs.futures[id] = fut - echo "jobs added: ", jobs.futures.unsafeAddr.pointer.repr, " => ", jobs.futures.keys().toSeq() + trace "jobs added: ", numberJobs = jobs.futures.len() return (JobResult[T](id: id, queue: jobs.queue), fut, ) proc newJobQueue*[T](maxItems: int = 0, taskpool: Taskpool = Taskpool.new()): JobQueue[T] {.raises: [ApatheiaSignalErr].} =