Skip to content

Commit 65cbbf5

Browse files
andre-salvaticlaude
andcommitted
feat: log external_source table totals after each seed run
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
1 parent 078bab2 commit 65cbbf5

1 file changed

Lines changed: 7 additions & 0 deletions

File tree

src/template/job1/seed_sources.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,13 @@ def run(self) -> None:
4848
self.logger.info("incremental seed date=%s", seed_date)
4949
self._seed_incremental(catalog, seed_date)
5050

51+
self.logger.info(
52+
"external_source totals: customers=%d orders=%d order_items=%d",
53+
self.spark.table(f"{catalog}.{SCHEMA}.customer").count(),
54+
self.spark.table(f"{catalog}.{SCHEMA}.order").count(),
55+
self.spark.table(f"{catalog}.{SCHEMA}.order_item").count(),
56+
)
57+
5158
# ------------------------------------------------------------------
5259
# Table bootstrap
5360
# ------------------------------------------------------------------

0 commit comments

Comments
 (0)