diff --git a/src/package.lisp b/src/package.lisp index f59901d..7914211 100644 --- a/src/package.lisp +++ b/src/package.lisp @@ -209,7 +209,10 @@ #:format-vector-row) (:import-from #:pgloader.sources #:map-rows - #:transforms) + #:transforms + #:target) + (:import-from #:pgloader.utils + #:pgstate-incf) (:export #:map-push-queue)) diff --git a/src/queue.lisp b/src/queue.lisp index ddcbecd..3674e2a 100644 --- a/src/queue.lisp +++ b/src/queue.lisp @@ -54,7 +54,8 @@ (incf count))) (condition (e) - (log-message :error "~a" e)))) + (log-message :error "~a" e) + (pgstate-incf *state* (target copy) :errs 1)))) (defun map-push-queue (copy queue &optional pre-formatted) "Apply MAP-ROWS on the COPY instance and a function of ROW that will push