Print extracted row counts to logger

martyngigg · martyngigg · commit 95bb6b7576ca · 2026-01-05T15:26:10.000Z
diff --git a/elt-common/src/elt_common/cli.py b/elt-common/src/elt_common/cli.py
@@ -112,6 +112,7 @@ def cli_main(
         write_disposition=args.write_disposition,
     )
     LOGGER.debug(pipeline.last_trace.last_extract_info)
+    LOGGER.debug(f"Extracted row counts: {pipeline.last_trace.last_normalize_info.row_counts}")
     LOGGER.debug(pipeline.last_trace.last_load_info)
     LOGGER.info(
         f"Pipeline {pipeline.pipeline_name} completed in {

Original file line number	Diff line number	Diff line change
`@@ -112,6 +112,7 @@ def cli_main(`
`112`	`112`	`write_disposition=args.write_disposition,`
`113`	`113`	`)`
`114`	`114`	`LOGGER.debug(pipeline.last_trace.last_extract_info)`
	`115`	`+ LOGGER.debug(f"Extracted row counts: {pipeline.last_trace.last_normalize_info.row_counts}")`
`115`	`116`	`LOGGER.debug(pipeline.last_trace.last_load_info)`
`116`	`117`	`LOGGER.info(`
`117`	`118`	`f"Pipeline {pipeline.pipeline_name} completed in {`