             (reset! second-message? true)
 
             (is (empty? (fs/list-dir (:path dlo))))
-            (let [failed-cmdref (async/<!! command-chan)]
+            (let [failed-cmdref (take-with-timeout!! command-chan default-timeout-in-ms)]
               (is (= 1 (count (:attempts failed-cmdref))))
               (is (re-matches
                    #"(?sm).*ERROR: could not serialize access due to concurrent update.*"


                  (is (empty? (fs/list-dir (:path dlo))))

                  (let [delayed-command (async/<!! command-chan)
                        actual-exception (:exception (first (:attempts delayed-command)))]
                    (are [x y] (= x y)
                      cmdref (dissoc delayed-command :attempts)

            (reset! second-message? true)
            (is (empty? (fs/list-dir (:path dlo))))

            (let [failed-cmdref (take-with-timeout!! command-chan default-timeout-in-ms)]
              (is (= 1 (count (:attempts failed-cmdref))))
              (is (re-matches
                   #"(?sm).*ERROR: could not serialize access due to concurrent update.*"
