                                      (tkey 0) (tkey 1) (tkey 2))
                        (catch Exception _ nil)))
 
-           (Thread/sleep 8000)          ; Wait for replication
+           (Thread/sleep 8000) ; Wait for replication
            (mq/stop tworker)
            (wcar* (car/del (tkey 0))
                   (car/set (tkey 2) [:clj-val-new])) ; Make some local modifications

               first
               ba->s))))

  (testing "Update val case"
    (tundra/put-key dstore (tkey :foo) (s->ba "hello world 1"))
    (tundra/put-key dstore (tkey :foo) (s->ba "hello world 2"))
    (is (= "hello world 2"

           (apply car/srem @#'tundra/k-evictable ks)))
  (wcar* (car/srem @#'tundra/k-evictable (tkey :invalid-evictable))))

(defn cleanup-fixture [f] (clean-up!) (f) (clean-up!))
(test/use-fixtures :once cleanup-fixture)

(def dstore (tdisk/disk-datastore "./carmine-tundra-test-temp"))

(defn- s->ba [^String s] (.getBytes s "UTF-8"))
(defn- ba->s [^bytes ba] (String.  ba "UTF-8"))

(deftest datastore-tests
  (test/testing "Basic put and fetch case"
    (tundra/put-key dstore (tkey :foo) (s->ba "hello world"))
    (is (= "hello world"
           (-> dstore
