 (defn import-links [dump-path]
   (println "Import Edges")
   (with-open [rdr (clojure.java.io/reader dump-path)]
-    (let [th-parse-pool (cp/threadpool 48)]
+    (let [th-parse-pool (cp/threadpool (cp/ncpus))]
       (cp/pdoseq
         th-parse-pool [line (line-seq rdr)]
         (try

  (start-server* {:server-name :morpheus
                  :port 5124
                  :zk  "10.0.1.104:2181"
                  :trunks-size "50gb"
                  :memory-size "50gb"
                  ;:schema-file "configures/neb-schemas.edn"
                  :data-path   "wikidata"
                  :durability true

(defn import-entities [dump-path lang]
  (println "Import Vertices")
  (let [lang (keyword lang)
        th-pool (cp/threadpool (cp/ncpus))]
    (with-open [rdr (clojure.java.io/reader dump-path)]
      (cp/pdoseq
        th-pool [line (line-seq rdr)]
