             (car/ttl (tkey 0)))))
 
 (comment (clean-up!)
-         (mq/queue-status {} "carmine.tundra"))
+         (mq/queue-status {} qname))

(let [tstore (tundra/tundra-store dstore)]
  (expect (and (:access-key creds) (:secret-key creds)))
  (expect Exception (wcar {} (tundra/dirty     tstore (tkey "invalid"))))
  (expect Exception (wcar {} (tundra/ensure-ks tstore (tkey "invalid")))))

(expect [[:clj-val] [:clj-val] [:clj-val-new]]
  (let [tstore  (tundra/tundra-store dstore)
        tworker (tundra/worker tstore {} {:eoq-backoff-ms 100 :throttle-ms 100})]
    (wcar {} (car/mset (tkey 0) [:clj-val]
                       (tkey 1) [:clj-val]
                       (tkey 2) [:clj-val])) ; Reset vals

    ;; Invalid keys throw w/o preventing valid keys from being processed
    (wcar {} (try (tundra/dirty tstore (tkey "invalid")
                                       (tkey 0) (tkey 1) (tkey 2))
                  (catch Exception _ nil)))


(comment (test/run-tests '[taoensso.carmine.tests.tundra]))

(defmacro wcar* [& body] `(car/wcar {:pool {} :spec {}} ~@body))
(def tkey (partial car/key :carmine :tundra :test))
(def qname "carmine-tundra-tests")
(defn clean-up! []
  (mq/clear-queues {} qname)
  (when-let [ks (seq (wcar* (car/keys (tkey :*))))]
    (wcar* (apply car/del ks))))

