WIP Use hardcoded timeout of 1 min (#210)

When processing a Flux workflow the process times out when taking more
than one minute.

Author: dr0i

project.clj

@@ -141,4 +141,5 @@
              :prep-tasks   ["compile" ["release"]]}}
 
   :prep-tasks []
+  :timeout [300000] ; after 5 minutes cancel the processing of a workflow
   :jvm-opts ["-Dclojure.tools.logging.factory=clojure.tools.logging.impl/slf4j-factory"])

src/clj/metafacture_playground/process.clj

@@ -20,8 +20,7 @@
         (log/trace "Content" content)
         file-path))))
 
-
-(defn process [flux data transformation]
+(defn process-in-timeout [flux data transformation]
   (let [inputfile (content->tempfile-path data ".data")
         transformationFile (content->tempfile-path transformation ".fix")
         out-path (content->tempfile-path "" ".txt")
@@ -34,3 +33,12 @@
     (Flux/main (into-array [(content->tempfile-path flux ".flux")]))
     (log/info "Executed flux file with Flux/main. Result in" out-path)
     (slurp out-path)))
+
+(defn process
+  "Runs process with a maximum wait of 1 min. Returns result or ::timeout."
+  [flux data transformation]
+  (let [fut (future (process-in-timeout flux data transformation))
+        result (deref fut 60000 ::timeout)]
+    (when (= result ::timeout)
+      (future-cancel fut))
+    result))