Skip to content

Commit 0b93a73

Browse files
committed
cleanup lint, implement jdbc
1 parent c9adb65 commit 0b93a73

20 files changed

Lines changed: 233 additions & 515 deletions

.clj-kondo/config.edn

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
intemporal.macros/env-let clojure.core/let
55
intemporal.macros/with-failure clojure.core/let
66
intemporal.store.foundationdb/with-tx clojure.core/with-open
7-
intemporal.test-utils/with-result clojure.core/let
7+
intemporal.tests.utils/with-result clojure.core/let
88

99
intemporal.core/with-workflow-engine clojure.core/let
1010

.gitignore

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,3 +39,6 @@ coverage/
3939
.venv/
4040
memory-bank/
4141
.claude
42+
43+
src2/
44+
test2/

cljs-todo.md

Lines changed: 0 additions & 48 deletions
This file was deleted.

cljs.md

Lines changed: 0 additions & 291 deletions
This file was deleted.

docker/fdb.cluster

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
docker:docker@172.19.0.2:4500
1+
docker:docker@192.168.107.2:4500

src/intemporal/core.cljc

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -187,8 +187,7 @@
187187
failed (p/find-event store workflow-id :async-failed handle-seq)]
188188
(cond
189189
completed
190-
(do
191-
(:result completed))
190+
(:result completed)
192191

193192
failed
194193
(throw (error/async-failed-exception handle-seq (:error failed)))

src/intemporal/internal/error.cljc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
(ns intemporal.internal.error
2-
(:require [clojure.string :as str])
2+
#?(:cljs (:require [clojure.string :as str]))
33
#?(:clj (:import (clojure.lang IExceptionInfo))))
44

55

src/intemporal/internal/execution.clj

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -115,8 +115,8 @@
115115
(if (a/should-retry? retry-policy (:exception exec-result) attempt)
116116
(let [backoff (a/calculate-backoff retry-policy attempt)]
117117
(log/debugf "Activity sleeping %s before retrying (attempt %d)" backoff attempt)
118-
(do (Thread/sleep (long backoff))
119-
(recur (inc attempt))))
118+
(Thread/sleep (long backoff))
119+
(recur (inc attempt)))
120120
;; else
121121
{:status :failed
122122
:error (:error exec-result)

0 commit comments

Comments
 (0)