                                                     :multipleId multiple-id
                                                     :multipleType multiple-type
                                                     :sort nil
+                                                    :splitable splitable
                                                     :title (string/trim title)
                                                     :type (name type)})
                                                  columns)

  (update-failed-job-execution conn {:id job-execution-id
                                     :reason [reason]})
  (drop-table conn {:table-name table-name}))


(defn val->geometry-pgobj
  [v]

      (let [spec (:spec (data-source-spec-by-job-execution-id conn {:job-execution-id job-execution-id}))]
        (with-open [importer (import/dataset-importer (get spec "source") config)]
          (let [columns (import/columns importer)
                records (import/records importer)
                stores (apply assoc {} (interleave columns (repeatedly #(atom {}))))
                rows-count (atom 0)]
            (import/create-dataset-table conn table-name columns)
            (import/add-key-constraints conn table-name columns)
            (doseq [record (map (comp import/coerce-to-sql (partial splitable stores columns)) records)]
              (swap! rows-count inc)
              (jdbc/insert! conn table-name record))
            (successful-import conn job-execution-id table-name
                               (map #(assoc % :splitable
                                            (map (fn [[k v]] [k (assoc v :rows @rows-count)]) @(last %2)))
                                    columns stores)
                               spec claims data-source))))
      (catch Throwable e
        (failed-import conn job-execution-id (.getMessage e) table-name)
        (log/error e)
