Testing Your Workflows

Overview

This Temporal Clojure SDK provides a test framework to facilitate Workflow unit-testing. The test framework includes an in-memory implementation of the Temporal service.

You can use the provided environment with a Clojure unit testing framework of your choice, such as clojure.test.

Example

(ns my.tests
  (:require [clojure.test :refer :all]
            [taoensso.timbre :as log]
            [temporal.client.core :as c]
            [temporal.testing.env :as e]
            [temporal.workflow :refer [defworkflow]]
            [temporal.activity :refer [defactivity] :as a]))

(def task-queue "MyTaskQueue")

(defactivity greet-activity
  [ctx {:keys [name] :as args}]
  (log/info "greet-activity:" args)
  (str "Hi, " name))

(defworkflow greeter-workflow
  [args]
  (log/info "greeter-workflow:" args)
  @(a/invoke greet-activity args))

(deftest my-test
  (testing "Verifies that we can invoke our greeter workflow"
    (let [env    (e/create)
          client (e/get-client env)]
      (e/start env {:task-queue task-queue})
      (let [workflow (c/create-workflow client greeter-workflow {:task-queue task-queue})]
        (c/start workflow {:name "Bob"}))
      (is (= @(c/get-result workflow) "Hi, Bob")))))

The primary difference between this test and a real-world application is the use of temporal.testing.env/create function. The features in the temporal.testing.env namespace allow you to create an instance of an in-memory Temporal service along with an associated Temporal worker and client connected to this instance.

Typical tests may opt to create the testing environment within a fixture, but this is left as an exercise to the reader.

The testing environment may be cleanly shutdown with temporal.testing.env/stop.