add workflow restart step

shh-jupyter · Sep 28, 2017 · 8e76c5d · 8e76c5d
1 parent 3229371
commit 8e76c5d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/project.clj b/project.clj
@@ -15,7 +15,7 @@
                  [datascript "0.15.5"]
                  [de.mpg.shh/util-properties "0.0.1"]
                  [de.mpg.shh/util-message-server "0.0.15"]
-                 [de.mpg.shh/util-overseer "0.0.54"]]
+                 [de.mpg.shh/util-overseer "0.0.67"]]
   :main overseer.core
   :source-paths ["src/main/clojure"]
   :profiles {:profiles {:uberjar {:aot :all}

diff --git a/src/main/clojure/overseer/component/endpoints_session_superuser.clj b/src/main/clojure/overseer/component/endpoints_session_superuser.clj
@@ -47,4 +47,7 @@
   :workflow-clear-all
   (fn [request-channel {data :data :as message}]
     (receive conn-overseer :workflow-clear-all data))
+  :workflow-restart-from-step
+  (fn [request-channel {data :data :as message}]
+    (receive conn-overseer :workflow-restart-from-step data))
            })))
diff --git a/src/main/clojure/overseer/component/endpoints_session_user.clj b/src/main/clojure/overseer/component/endpoints_session_user.clj
@@ -35,12 +35,12 @@
     (error "error session endpoint received: " message))
   :ping
   (fn [request-channel message]
-    (info "got ping: " message)
+    ;;(info "got ping: " message)
     (reply request-channel (:client-id message) [:pong {}]))
   ;; Overseer client api calls, e.g. registering a runtime or accepting a task
   :status
   (fn [request-channel message]
-    (let [_ (info "got status: " (pr-str message))
+    (let [;;_ (info "got status: " (pr-str message))
           result (try
                    {:data (overseer-server/status conn-overseer)}
                    (catch Throwable t