diff options
author | Alan Pearce | 2024-05-14 17:23:22 +0200 |
---|---|---|
committer | Alan Pearce | 2024-05-14 17:23:22 +0200 |
commit | 56406890b7ff3cd05cada498456110b72777ccd0 (patch) | |
tree | d26a0cb4e2145bbce417326124750bafa6e235ab /internal/importer/importer.go | |
parent | 37afa6ce04434b81fcb242f1160938f1cddbde1e (diff) | |
download | searchix-56406890b7ff3cd05cada498456110b72777ccd0.tar.lz searchix-56406890b7ff3cd05cada498456110b72777ccd0.tar.zst searchix-56406890b7ff3cd05cada498456110b72777ccd0.zip |
refactor(importer): add context and reduce log level
Diffstat (limited to 'internal/importer/importer.go')
-rw-r--r-- | internal/importer/importer.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/internal/importer/importer.go b/internal/importer/importer.go index a242481..b66b6d3 100644 --- a/internal/importer/importer.go +++ b/internal/importer/importer.go @@ -78,7 +78,7 @@ func processOptions( if !running { wg.Done() iErrs = nil - slog.Info("ingest completed") + conf.Logger.Info("ingest completed") continue } @@ -88,7 +88,7 @@ func processOptions( if !running { wg.Done() pErrs = nil - slog.Info("processing completed") + conf.Logger.Debug("processing completed") continue } @@ -98,9 +98,9 @@ func processOptions( } }() - slog.Debug("options processing", "state", "waiting") + conf.Logger.Debug("options processing", "state", "waiting") wg.Wait() - slog.Debug("options processing", "state", "complete") + conf.Logger.Debug("options processing", "state", "complete") return hadErrors, nil } |