 (deftest changed-email-stage-test
   (testing "that you deliver an alert to POST when a worker changes"
     (let [stage ((:factory (get (hive-data-stages-specs) :change-email))
-                 { :in  {:worker "test"}
-                   :url "http://email-hook.com"})]
+                 {:params
+                  { :in  {:worker "test"}
+                    :url "http://email-hook.com"
+                  }})]
       ;; We want to push in some worker data.
       ;; Since it is going from both workers to the output
       (conjure/mocking [push-email-alert]

        )
      ))
  (testing "that hive -> hive works"
    (let [stage ((:factory (get (hive-data-stages-specs) :average)) {:in {:hive "test"}
                                                   :out {:hive "test-avg"}
                                                   :window 0
                                                   })]
      ;; We want to push in some worker data.
      ;; Since it is going from both workers to the output
      (conjure/mocking [push-data]


(deftest average-stage-test
  (testing "that worker -> hive works"
    (let [stage ((:factory (get (hive-data-stages-specs) :average)) {
                                                                     :params {
                                                                               :in {:worker "test"}
                                                                               :out {:hive "test-avg"}
                                                                               :window 0}
                                                   })]
      ;; We want to push in some worker data.
      ;; Since it is going from both workers to the output
