Fill in more WorkflowOptions

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

Author: ghaskins

src/temporal/internal/workflow.clj

@@ -11,9 +11,15 @@
            [io.temporal.client WorkflowOptions WorkflowOptions$Builder]))
 
 (def wf-option-spec
-  {:task-queue    #(.setTaskQueue ^WorkflowOptions$Builder %1 (u/namify %2))
-   :workflow-id   #(.setWorkflowId ^WorkflowOptions$Builder %1 %2)
-   :retry-options #(.setRetryOptions %1 (common/retry-options-> %2))})
+  {:task-queue                 #(.setTaskQueue ^WorkflowOptions$Builder %1 (u/namify %2))
+   :workflow-id                #(.setWorkflowId ^WorkflowOptions$Builder %1 %2)
+   :workflow-execution-timeout #(.setWorkflowExecutionTimeout ^WorkflowOptions$Builder %1 %2)
+   :workflow-run-timeout       #(.setWorkflowRunTimeout ^WorkflowOptions$Builder %1 %2)
+   :workflow-task-timeout      #(.setWorkflowTaskTimeout ^WorkflowOptions$Builder %1 %2)
+   :retry-options              #(.setRetryOptions %1 (common/retry-options-> %2))
+   :cron-schedule              #(.setCronSchedule ^WorkflowOptions$Builder %1 %2)
+   :memo                       #(.setMemo ^WorkflowOptions$Builder %1 %2)
+   :search-attributes          #(.setSearchAttributes ^WorkflowOptions$Builder %1 %2)})
 
 (defn wf-options->
   ^WorkflowOptions [params]

test/temporal/test/types.clj

@@ -0,0 +1,20 @@
+;; Copyright © 2022 Manetu, Inc.  All rights reserved
+
+(ns temporal.test.types
+  (:require [clojure.test :refer :all]
+            [temporal.internal.workflow :as workflow])
+  (:import [java.time Duration]))
+
+(deftest workflow-options
+  (testing "Verify that our workflow options work"
+    (let [x (workflow/wf-options-> {:workflow-id "foo"
+                                    :task-queue "bar"
+                                    :workflow-execution-timeout (Duration/ofSeconds 1)
+                                    :workflow-run-timeout (Duration/ofSeconds 1)
+                                    :workflow-task-timeout (Duration/ofSeconds 1)
+                                    :retry-options {:maximum-attempts 1}
+                                    :cron-schedule "* * * * *"
+                                    :memo {"foo" "bar"}
+                                    :search-attributes {"foo" "bar"}})]
+      (is (-> x (.getWorkflowId) (= "foo")))
+      (is (-> x (.getTaskQueue) (= "bar"))))))