             (common/create-dataset-table conn table-name columns)
             (doseq [record (map common/coerce-to-sql (p/records importer))]
               (jdbc/insert! conn table-name record))
-            (successful-import conn job-execution-id table-name columns spec claims data-source))))
+            (successful-import conn job-execution-id table-name columns spec claims))))
       (catch Throwable e
         (failed-import conn job-execution-id (.getMessage e) table-name)
         (log/error e)

                                  :transformations []})
    (update-successful-job-execution conn {:id job-execution-id})))

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

                                     :spec (json/generate-string data-source)})
    (insert-job-execution tenant-conn {:id job-execution-id
                                       :data-source-id data-source-id})
    (future (do-import tenant-conn config error-tracker job-execution-id claims))
    (lib/ok {"importId" job-execution-id
             "kind" kind})))
