diff --git a/pipeline/plugins/extractors/tap-uk-ofsted/tap_uk_ofsted/tap.py b/pipeline/plugins/extractors/tap-uk-ofsted/tap_uk_ofsted/tap.py
index 8f23d13..f1ba1f9 100644
--- a/pipeline/plugins/extractors/tap-uk-ofsted/tap_uk_ofsted/tap.py
+++ b/pipeline/plugins/extractors/tap-uk-ofsted/tap_uk_ofsted/tap.py
@@ -148,6 +148,8 @@ class OfstedInspectionsStream(Stream):
             )
 
         col_map = self._resolve_columns(list(df.columns))
+        self.logger.info("CSV columns: %s", list(df.columns))
+        self.logger.info("Resolved column map: %s", col_map)
 
         for _, row in df.iterrows():
             record = {}