fix jepsen timeout

yandex · Oct 2, 2024 · 4c1b222 · 4c1b222
1 parent adae5dd
commit 4c1b222
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
-          (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)))))
+          (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)))))
         (catch Throwable t#
           (let [m# (.getMessage t#)]
             (cond