Add workflow/sleep

Signed-off-by: Greg Haskins <[email protected]>

Author: ghaskins

src/temporal/workflow.clj

@@ -27,6 +27,11 @@
   ([^Duration duration pred]
    (Workflow/await duration (->supplier pred))))
 
+(defn sleep
+  "Efficiently parks the workflow for 'duration'"
+  [^Duration duration]
+  (Workflow/sleep duration))
+
 (defmacro defworkflow
   "
 Defines a new workflow, similar to defn, expecting a 2-arity parameter list and body.  Should evaluate to something

test/temporal/test/sleep.clj

@@ -0,0 +1,27 @@
+;; Copyright © 2022 Manetu, Inc.  All rights reserved
+
+(ns temporal.test.sleep
+  (:require [clojure.test :refer :all]
+            [taoensso.timbre :as log]
+            [temporal.client.core :as c]
+            [temporal.workflow :refer [defworkflow] :as w]
+            [temporal.test.utils :as t])
+  (:import [java.time Duration]))
+
+(use-fixtures :once t/wrap-service)
+
+(defworkflow sleep-workflow
+  [ctx {:keys [signals] :as args}]
+  (log/info "sleep-workflow:" args)
+  (w/sleep (Duration/ofSeconds 1))
+  :ok)
+
+(defn create []
+  (let [wf (c/create-workflow (t/get-client) sleep-workflow {:task-queue t/task-queue})]
+    (c/start wf nil)
+    wf))
+
+(deftest the-test
+  (testing "Verifies that signals may timeout properly"
+    (let [wf (create)]
+      (is (= @(c/get-result wf) :ok)))))