fix shutdown

mping · Feb 3, 2025 · 5bb1c8e · 5bb1c8e
1 parent 2ff8021
commit 5bb1c8e
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/intemporal/workflow.cljc b/src/intemporal/workflow.cljc
@@ -52,7 +52,8 @@
          (submit [_ f]
            (when @run?
              (p/vthread (f))))
-         (shutdown [_ grace-period-ms] (reset! run? false))
+         (shutdown [_ grace-period-ms]
+           (reset! run? false))
          (running? [_] @run?))
        :clj
        (Executors/newVirtualThreadPerTaskExecutor))))
@@ -125,7 +126,7 @@
                         (when-let [task (store/dequeue-task store)]
                           (t/log! {:level :debug :_data {:task task}} ["Dequeued task with id" (:id task)])
                           (p/vthread
-                            (worker-execute-fn store protocols task task-counter (fn [] @run?))))
+                            (worker-execute-fn store protocols task task-counter (fn [] (not @run?)))))
                         (when @run?
                           (p/recur)))))))
      (fn [] (reset! run? false)))))