    (cass-execute query {}))
   ([query opts]
    (let [opts (merge {:consistency :one} opts)]
-     (log/spy
-     (alia/execute (:session @cass-state) query opts))))
-  )
+     (alia/execute-async (:session @cass-state) query opts))))
 
 (defn cass-prepared-insert [& data]
-  (log/info "Inserting the following data: " data)
+  ;(log/info "Inserting the following data: " data)
   (cass-execute (:prepared-insert @cass-state) {:values data}))
 
 (defn init-cass

  ([options]
   (log/info "Initializing connections to cassandra")
   (let [cluster (alia/cluster {:contact-points (get options :nodes ["localhost"])
                                :port (get options :port 9042)})
         session (alia/connect cluster)]

     (alia/execute session (use-keyspace "DATA"))

     (reset! cass-state
             {:cluster cluster

        :let [{:keys [tenantId metricName
                      metricValue collectionTime]} datapoint
              metric-name (str tenantId "." metricName)]]
    (cass-prepared-insert metric-name collectionTime (str metricValue))))


(defn solo-ingest-handler [req]
  (log/info "I was asked to handle a request for a single tenant")
  (for [x (doall (ingest-processor
                   (map #(assoc % :tenantId (get-in req [:params :tenant-id])) (:body req) )))]
    @x)
  (response ""))


(defn ingest-handler [req]
  (log/info "OMG A WHALE SHOWED UP!")
  (for [x (doall (ingest-processor (:body req)))]
      @x)
  (response ""))


(defn- json-request? [request]
