DB/Add exponential backoff before trying the table creation (#119)

scalar-labs · Dec 20, 2023 · 123fc61 · 123fc61
1 parent 2f774a4
commit 123fc61
Showing 1 changed file with 6 additions and 10 deletions.
diff --git a/scalardb/src/scalardb/core.clj b/scalardb/src/scalardb/core.clj
@@ -31,21 +31,17 @@
       (loop [retries RETRIES]
         (when (zero? retries)
           (throw (ex-info "Failed to set up tables" {:schema schema})))
+        (when (< retries RETRIES)
+          (try
+            (SchemaLoader/unload properties schema true)
+            (catch Exception e (warn (.getMessage e))))
+          (exponential-backoff (- RETRIES retries)))
         (let [schema (cheshire/generate-string schema)
               result (try
-                       (SchemaLoader/load properties
-                                          schema
-                                          options
-                                          true)
+                       (SchemaLoader/load properties schema options true)
                        :success
                        (catch Exception e
                          (warn (.getMessage e))
-                         (try
-                           (SchemaLoader/unload properties
-                                                schema
-                                                true)
-                           (catch Exception e
-                             (warn (.getMessage e))))
                          :fail))]
           (when (= result :fail)
             (recur (dec retries))))))))