   {:internal (:internal-url flow-api)
    :url (:url flow-api)})
 
-(defn adapter [file version rows-cols col*]
-  col*)
+(defn adapter [{:keys [version rows-cols instance survey-id form-id]} data]
+  data)
 
 (defmethod import/dataset-importer "AKVO_FLOW"
   [{:strs [instance surveyId formId token email version] :as spec}

      p/DatasetImporter
      (columns [this]
        (try
          (let [res (cond
                  (<= version 2) (v2/dataset-columns (flow-common/form @survey formId) environment)
                  (<= version 3) (v3/dataset-columns (flow-common/form @survey formId) environment))]
            (adapter (format "%s-%s-%s" instance surveyId formId) 3 :cols res))
          (catch Throwable e
            (if-let [ex-d (ex-data e)]
              (do

              (throw e)))))
      (records [this]
        (try
          (let [data (v4/form-data headers-fn instance @survey formId)]
              (adapter {:version 4
                      :rows-cols :rows
                      :instance instance
                      :survey-id surveyId
                      :form-id formId} data))
          (catch Throwable e
            (if-let [ex-d (ex-data e)]
              (throw (ex-info (or (:cause e) (str "Null cause from instance: " instance))
