test(orchestration): include crypto_tstrend_nav in definitions asset-set assertions

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
This commit is contained in:
jgrusewski
2026-06-21 00:43:41 +02:00
parent fd27117382
commit 5aeaa8913a

View File

@@ -23,9 +23,10 @@ def test_definitions_load_with_assets_and_schedule() -> None:
# the 2 validated crypto edges are wired in
assert "xsfunding_nav" in asset_keys, f"missing xsfunding_nav asset: {asset_keys}"
assert "unlock_nav" in asset_keys, f"missing unlock_nav asset: {asset_keys}"
# 7 assets: crypto_bars, futures_bars, combined_forward_nav, sixtyforty_nav,
# xsfunding_nav, unlock_nav, cockpit_forward
assert len(asset_keys) == 7, f"expected 7 assets, got {len(asset_keys)}: {asset_keys}"
assert "crypto_tstrend_nav" in asset_keys, f"missing crypto_tstrend_nav asset: {asset_keys}"
# 8 assets: crypto_bars, futures_bars, combined_forward_nav, sixtyforty_nav,
# xsfunding_nav, unlock_nav, crypto_tstrend_nav, cockpit_forward
assert len(asset_keys) == 8, f"expected 8 assets, got {len(asset_keys)}: {asset_keys}"
# --- schedule present with the right cron ---
# defs.schedules is a list[ScheduleDefinition] (or None when empty)
@@ -43,5 +44,5 @@ def test_definitions_load_with_assets_and_schedule() -> None:
cockpit_def = repo.assets_defs_by_key[AssetKey("cockpit_forward")]
deps = cockpit_def.asset_deps[AssetKey("cockpit_forward")]
upstream = {k.to_user_string() for k in deps}
expected_upstream = {"combined_forward_nav", "xsfunding_nav", "unlock_nav", "sixtyforty_nav"}
expected_upstream = {"combined_forward_nav", "xsfunding_nav", "unlock_nav", "sixtyforty_nav", "crypto_tstrend_nav"}
assert expected_upstream <= upstream, f"cockpit_forward missing upstream: {expected_upstream - upstream}"