diff --git a/k8s/railiance/20-runtime.yaml b/k8s/railiance/20-runtime.yaml index c527b25..657b979 100644 --- a/k8s/railiance/20-runtime.yaml +++ b/k8s/railiance/20-runtime.yaml @@ -170,10 +170,10 @@ data: name: "State Hub Consistency Sweep" type: activity-definition version: "1.0" - enabled: false + enabled: true owner: custodian governance: custodian - status: proposed + status: active created: "2026-06-21" trigger: type: cron @@ -186,6 +186,7 @@ data: required: true params: max_seconds: 300 + source: activity-core bind_to: context.consistency_sweep_remote_all --- diff --git a/tests/test_state_hub_context_resolver.py b/tests/test_state_hub_context_resolver.py index 4cf968d..0f8727e 100644 --- a/tests/test_state_hub_context_resolver.py +++ b/tests/test_state_hub_context_resolver.py @@ -429,7 +429,7 @@ def test_consistency_sweep_remote_all_posts_batch(monkeypatch) -> None: result = StateHubContextResolver().resolve( "consistency_sweep_remote_all", None, - {"max_seconds": 300, "required": True}, + {"max_seconds": 300, "source": "activity-core", "required": True}, ) assert result["exit_code"] == 0 @@ -437,7 +437,7 @@ def test_consistency_sweep_remote_all_posts_batch(monkeypatch) -> None: assert calls == [ { "url": "http://state-hub.test/consistency/sweep/remote-all", - "json": {"max_seconds": 300}, + "json": {"max_seconds": 300, "source": "activity-core"}, "timeout": 330.0, } ]