diff --git a/tests/integration/test_orchestration_definitions.py b/tests/integration/test_orchestration_definitions.py index b9821af..a35dd29 100644 --- a/tests/integration/test_orchestration_definitions.py +++ b/tests/integration/test_orchestration_definitions.py @@ -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}"