test(assets): let the event-log manifest express a call site's real multiplicity

This commit is contained in:
Simon Pinfold
2026-09-17 18:31:43 -07:00
parent d4f64f7558
commit 3604ba4e47
+6 -4
View File
@@ -39,9 +39,10 @@ class CallSite(NamedTuple):
# The manifest of every tagged event this branch emits: (file, enclosing
# function, event) triples that must be present in the tree exactly as written.
EXPECTED_CALL_SITES: frozenset[CallSite] = frozenset(
{
# function, event) triples that must be present in the tree with their exact
# multiplicity.
EXPECTED_CALL_SITES: Counter[CallSite] = Counter(
(
# todo 10 - seeder lifecycle + the single assets.enabled site
CallSite("server.py", "__init__", "assets.enabled"),
CallSite("app/assets/seeder.py", "_run_scan", "seeder.scan_started"),
@@ -60,13 +61,14 @@ EXPECTED_CALL_SITES: frozenset[CallSite] = frozenset(
CallSite("app/assets/scanner.py", "_prepare_enrichment", "scanner.hash_failed"),
CallSite("app/assets/scanner.py", "_prepare_enrichment", "scanner.hash_discarded_modified"),
CallSite("app/assets/scanner.py", "enrich_assets_batch", "scanner.enrich_failed"),
CallSite("app/assets/scanner.py", "enrich_assets_batch", "scanner.enrich_failed"),
# todo 16 - discovery/enrich stat failures, emit-once per scan per site
CallSite("app/assets/scanner.py", "build_asset_specs", "scanner.stat_failed"),
CallSite("app/assets/scanner.py", "_prepare_enrichment", "scanner.stat_failed"),
CallSite("app/assets/scanner.py", "_publish_reference_diagnostics", "scanner.stat_failed"),
CallSite("app/assets/services/ingest.py", "register_cached_output", "ingest.register_failed"),
CallSite("app/assets/services/ingest.py", "register_executed_output", "ingest.register_failed"),
}
)
)
class Aliases(NamedTuple):