Timeout reason investigations

yandex · Oct 10, 2024 · fb9b05f · fb9b05f
1 parent 58c15e8
commit fb9b05f
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 6 deletions.
diff --git a/.github/workflows/docker-jepsen.yml b/.github/workflows/docker-jepsen.yml
@@ -3,6 +3,10 @@ name: Jepsen tests
 on:
   schedule:
     - cron: '0 0 * * *'
+  push:
+    branches: [ master ]
+  pull_request:
+    branches: [ master ]
 
 env:
   GO_VERSION: 1.22.4

diff --git a/tests/images/jepsen_main/jepsen/src/jepsen/mysync.clj b/tests/images/jepsen_main/jepsen/src/jepsen/mysync.clj
@@ -96,7 +96,7 @@
               :read (timeout 120000 (assoc op :type :info, :error "read-timeout")
                       (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"]
+                                    :value (->> (j/query c ["select value from test1.test_set limit 10"]
                                                           {:row-fn :value})
                                                 (vec)
                                                 (set)))
@@ -110,8 +110,8 @@
         (catch Throwable t#
           (let [m# (.getMessage t#)]
             (cond
-              (re-find #"The MySQL server is running with the --(super-)?read-only option so it cannot execute this statement" m#) (assoc op :type :info, :error "read-only")
-              (re-find #"The server is currently in offline mode" m#) (assoc op :type :info, :error "offline")
+              (re-find #"The MySQL server is running with the --(super-)?read-only option so it cannot execute this statement" m#) (assoc op :type :info, :error "catch-read-only")
+              (re-find #"The server is currently in offline mode" m#) (assoc op :type :info, :error "catch-offline")
               true (do
                      (warn (str "Query error: " m# " on adding: " (get op :value)))
                      (assoc op :type :info, :error m#)
@@ -270,13 +270,13 @@
                                     {:type :sleep, :value 60}
                                     {:type :info, :f :stop}
                                     {:type :sleep, :value 60}])))
-                     (gen/time-limit 7200))
+                     (gen/time-limit 720))
                 (->> r
                      (gen/stagger 1)
                      (gen/nemesis
                        (fn [] (map gen/once
                                    [{:type :info, :f :stop}
-                                    {:type :sleep, :value 240}])))
-                     (gen/time-limit 600)))
+                                    {:type :sleep, :value 600}])))
+                     (gen/time-limit 1200)))
    :checker   mysync-set
    :remote    control/ssh})