From 903152b0b264bd5eb8548b63e4557f37ee561546 Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Fri, 16 Feb 2024 15:00:20 -0700
Subject: [PATCH] rename

---
 src/apatheia/jobs.nim | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/apatheia/jobs.nim b/src/apatheia/jobs.nim
index 5905167..dbbbe31 100644
--- a/src/apatheia/jobs.nim
+++ b/src/apatheia/jobs.nim
@@ -43,7 +43,7 @@ template toOpenArray*[T](arr: OpenArrayHolder[T]): auto =
 func jobId*[T](fut: Future[T]): JobId =
   JobId fut.id()
 
-proc processJobs*[T](jobs: JobQueue[T]) {.async.} =
+proc processJobs*[T](jobs: JobQueue[T]) {.async, raises: [].} =
   ## Starts a "detached" async processor for a given job queue.
   ## 
   ## This processor waits for events from the queue in the JobQueue
@@ -52,13 +52,13 @@ proc processJobs*[T](jobs: JobQueue[T]) {.async.} =
   const tn: string = $(JobQueue[T])
   info "Processing jobs in job queue for type ", type = tn
   while jobs.running:
-    let res = await(jobs.queue.wait()).get()
-    trace "got job result", jobResult = $res
-    let (id, ret) = res
-    releaseMemory(id) # release any retained memory
+    let (id, ret) = await(jobs.queue.wait()).get()
+    trace "got job result", jobId = id
+    releaseMemory(id) # always release any retained memory
     var fut: Future[T]
     if jobs.futures.pop(id, fut):
-      fut.complete(ret)
+      if not fut.finished():
+        fut.complete(ret)
     else:
       raise newException(IndexDefect, "missing future: " & $id)
   info "Finishing processing jobs for type ", type = tn