diff --git a/src/sources/csv/csv.lisp b/src/sources/csv/csv.lisp index a2345c8..19446dd 100644 --- a/src/sources/csv/csv.lisp +++ b/src/sources/csv/csv.lisp @@ -71,6 +71,7 @@ (handler-bind ((cl-csv:csv-parse-error #'(lambda (c) (log-message :error "~a" c) + (update-stats :data (target csv) :errs 1) (cl-csv::continue)))) (cl-csv:read-csv stream :row-fn process-fn @@ -84,6 +85,6 @@ :newline (csv-newline csv))) (condition (e) (progn - (log-message :error "~a" e) + (log-message :fatal "~a" e) (update-stats :data (target csv) :errs 1))))) diff --git a/src/utils/monitor.lisp b/src/utils/monitor.lisp index 5564d3f..0162aa5 100644 --- a/src/utils/monitor.lisp +++ b/src/utils/monitor.lisp @@ -220,6 +220,7 @@ :read (update-stats-read event) :rows (update-stats-rows event) :secs (update-stats-secs event) + :errs (update-stats-errs event) :rs (update-stats-rs event) :ws (update-stats-ws event)))