 (defn check-results
   "TODO: Move over to edb proper."
   [dpath pairs]
-  (is (= (set (read-etap-with-flow dpath))
-         (set pairs))))
+  (fact pairs => (just (read-etap-with-flow dpath) :in-any-order)))
 
 ;; TODO: Invalid. Doesn't belong in this project; this makes far too
 ;; many assumptions about a thrift interface, etc. All we're concerned
 ;; about here is getting data in and out of edb w/ cascading.
-(deftest test-basic
+(fact "test basic"
   (with-fs-tmp [fs tmp]
     (let [spec (DomainSpec. (JavaBerkDB.) (HashModScheme.) 4)
           sink (ElephantDBTap. tmp spec (mk-options :indexer nil))

               (HashModScheme.)
               4))

(defn populate [idx]
  (with-open [shard (.createShard spec "/Users/sritchie/Desktop/helper" idx)]
    (doseq [x (range 1000)]
      (.index shard (KeyValDocument. x 10)))))

;; or, you can create a domain store directly:
(def store
  (DomainStore. "/Users/sritchie/Desktop/helper"
                (DomainSpec. (JavaBerkDB.)
                             (HashModScheme.)
                             4)))

      (fill-domain sink data2)
      (check-results tmp data3))))

(fact "test-source"
  (with-fs-tmp [fs tmp]
    (let [pairs [[(barr 0) (barr 0 2)]
                 [(barr 1) (barr 1 1)]
