Skip to content
Snippets Groups Projects
Commit bc8ff64f authored by Simon Belak's avatar Simon Belak
Browse files

Add async/cancled? predicate

parent 9446edfb
No related branches found
No related tags found
No related merge requests found
......@@ -19,6 +19,10 @@
"Is the computation job still running?"
(comp some? #{:running} :status))
(def ^{:arglists '([job])} canceled?
"Has the computation job been canceled?"
(comp some? #{:canceled} :status))
(defn- save-result
[{:keys [id]} payload]
(when-not (future-cancelled? (@running-jobs id))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment