aboutsummaryrefslogtreecommitdiff
path: root/src/clj/queue_api/db/core.clj
diff options
context:
space:
mode:
Diffstat (limited to 'src/clj/queue_api/db/core.clj')
-rw-r--r--src/clj/queue_api/db/core.clj9
1 files changed, 7 insertions, 2 deletions
diff --git a/src/clj/queue_api/db/core.clj b/src/clj/queue_api/db/core.clj
index c76f0fb..0482feb 100644
--- a/src/clj/queue_api/db/core.clj
+++ b/src/clj/queue_api/db/core.clj
@@ -102,7 +102,12 @@
(if (seq jn)
(first jn))))))
-(defn request-job
+(defn agent
+ "Get a agent by id"
+ [id]
+ (d/entity @conn [:agent/id id]))
+
+(defn fittest-job
"Get the fittest job for a agent `id`."
[^String id]
(let [a (d/entity @conn [:agent/id id])]
@@ -146,7 +151,7 @@
[^String id]
(let [a (d/entity @conn [:agent/id id])]
(if-not (nil? a)
- (let [jid (:job/id (request-job id))]
+ (let [jid (:job/id (fittest-job id))]
(end-job a)
(start-job id jid)
jid)))) \ No newline at end of file