                                           {:values [% tenant (int rollup)
                                                     (int period)
                                                     from to]
-                                           :fetch-size Integer/MAX_VALUE}))]
+                                           :fetch-size Integer/MAX_VALUE
+                                           }))]
+                           (doall rows)
                            (when rows
                              (doseq [row rows]
                                (let [time (long (:time row))

           batch_size 100}}]
  (info "creating cassandra metric store")
  (let [cluster (if (sequential? cluster) cluster [cluster])
        session (-> (alia/cluster {:contact-points cluster
                                   :pooling-options {:max-connections-per-host {:local 8192
                                                                                :remote 8192}}})
                    (alia/connect keyspace))
        insert! (insertq session)
        fetch!  (fetchqp session)]

   swap implementations"
  (:require [clojure.string              :as str]
            [qbits.alia                  :as alia]
            [qbits.alia.policy.load-balancing :as alia_lbp]
            [org.spootnik.cyanite.util   :refer [partition-or-time
                                                 go-forever go-catch
                                                 counter-inc!
