                      :password password})]
     (with-test-env [test-env [4 env-config peer-config]]
       (ensure-database! username password subname db-name)
-      (pipe (spool words) in true)
+      (pipe (spool all-words) in true)
       (onyx.test-helper/validate-enough-peers! test-env job)
       (->> (:job-id (onyx.api/submit-job peer-config job))
            (onyx.api/await-job-completion peer-config))

   {:id 4 :word "Door"}
   {:id 5 :word "Surf board"}])

(defn ensure-database! [db-user db-pass db-sub-base db-name]
  (let [db-spec {:classname "com.mysql.jdbc.Driver"
                 :subprotocol "mysql"

              :words
              [[:id :int "PRIMARY KEY"]
               [:word "VARCHAR(32)"]])))
    (doseq [word all-words]
      (jdbc/execute! cpool (mysql/upsert :words
                                         (dissoc word :id)
                                         (dissoc word :word))))))

(defn transform-word
  [word]
