logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-07 07:23:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

cleanup

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-16 14:26:14 -07:00
parent 1dfdbe8e1f
commit 2842aaaf02
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/apatheia/jobs.nim
View File

@ -27,7 +27,7 @@ type
taskpool*: Taskpool
running*: bool
JobResult*[T] = object ## hold a job result to be returned by jobs
JobResult*[T] = object ## hold the result of a job after it finishes
id*: JobId
queue*: SignalQueue[(JobId, T)]
@ -103,14 +103,10 @@ macro submitMacro(tp: untyped, jobs: untyped, exp: untyped): untyped =
var argids = newSeq[NimNode]()
var letargs = nnkLetSection.newTree()
for i, p in exp[1 ..^ 1]:
echo "CHECK ARGS: ", p.treeRepr
let id = ident "arg" & $i
argids.add(id)
let pn = nnkCall.newTree(ident"checkJobArgs", p, `futName`)
letargs.add nnkIdentDefs.newTree(id, newEmptyNode(), pn)
# fncall.add(nnkCall.newTree(ident"checkJobArgs", p, `futName`))
echo "\nSUBMIT: ARGS: LET:\n", letargs.repr
echo ""
var fncall = nnkCall.newTree(exp[0])
fncall.add(jobRes)
@ -141,7 +137,6 @@ when isMainModule:
import os
import chronos/threadsync
import chronos/unittest2/asynctests
import std/macros
proc addNumValues(
jobResult: JobResult[float], base: float, vals: OpenArrayHolder[float]