                            (shutdown-agents)
                            (throw e))))
                     paths))]
-    (map deref futures)))
+    (map my-deref futures)))
 
 (defn par-fetch-pmap
   "Fetch data in parallel fashion using pmap."

  [f-par-fetch host paths tenant rollup period from to]
  (println "Connecting to Cassandra...")
  (let [cluster (alia/cluster {:contact-points [host]})
        session (alia/connect keyspace cluster)
        fetch! (fetchq session)]
    (println "Getting data form Cassandra...")
    (try

                                                          (seq)
                                                          (swap! data conj)))})
                    paths))]
    (map my-deref channels)
    @data))

(defn c-get-data
