             (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.*"

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

            (let [failed-cmdref (async/<!! command-chan)]
              (is (= 1 (count (:attempts failed-cmdref))))
              (is (re-matches
                   #"(?sm).*ERROR: could not serialize access due to concurrent update.*"


            (handle-message (store-command' q new-facts-cmd))
            (reset! second-message? true)
            (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.*"
