Let's check it with the old timeout...

yandex · Oct 6, 2024 · 4a9b54c · 4a9b54c
1 parent 3123198
commit 4a9b54c
Showing 1 changed file with 15 additions and 15 deletions.
diff --git a/tests/images/jepsen_main/jepsen/src/jepsen/mysync.clj b/tests/images/jepsen_main/jepsen/src/jepsen/mysync.clj
@@ -91,21 +91,21 @@
 
     (invoke! [this test op]
       (try
-          (with-conn [c conn]
-            (case (:f op)
-              :read (cond (= (count (j/query c ["show slave status for channel ''"])) 0)
-                          (assoc op :type :ok,
-                                    :value (->> (j/query c ["select value from test1.test_set"]
-                                                          {:row-fn :value})
-                                                (vec)
-                                                (set)))
-                          true
-                          (assoc op :type :info, :error "read-only"))
-              :add (timeout 5000 (assoc op :type :info, :error "timeout")
-                    (do
-                      (info (str "Adding: " (get op :value) " to " (get c :subname)))
-                      (j/execute! c [(str "insert into test1.test_set values ('" (get op :value) "')")])
-                      (assoc op :type :ok)))))
+          (timeout 5000 (assoc op :type :info, :error "timeout")
+            (with-conn [c conn]
+              (case (:f op)
+                :read (cond (= (count (j/query c ["show slave status for channel ''"])) 0)
+                            (assoc op :type :ok,
+                                      :value (->> (j/query c ["select value from test1.test_set"]
+                                                           {:row-fn :value})
+                                                  (vec)
+                                                  (set)))
+                            true
+                            (assoc op :type :info, :error "read-only"))
+                :add (do
+                       (info (str "Adding: " (get op :value) " to " (get c :subname)))
+                       (j/execute! c [(str "insert into test1.test_set values ('" (get op :value) "')")])
+                       (assoc op :type :ok)))))
         (catch Throwable t#
           (let [m# (.getMessage t#)]
             (cond