         from (long from)
         to (long to)
         asize (inc (time-to-ndx from rollup to))
-        series (atom ())
         futures
         (doall (map #(future
                        (try

                                         :remote 128}
                                        :load-balancing-policy
                                        (alia_lbp/token-aware-policy
                                         (alia_lbp/dc-aware-round-robin-policy ""))}
                      :socket-options {:read-timeout-millis 1000000
                                       :receive-buffer-size 8388608
                                       :send-buffer-size 1048576

  (let [cluster (if (sequential? cluster) cluster [cluster])
        session (-> (alia/cluster
                     {:contact-points cluster
                      ;;:compression :lz4
                      :pooling-options {:max-connections-per-host
                                        {:local 8192
                                         :remote 8192}
