From faf5d60ae825150584cac9268e0e6aa69c4b4ac8 Mon Sep 17 00:00:00 2001 From: tegwick Date: Sun, 21 Jun 2026 21:46:43 +0200 Subject: [PATCH] feat(STATE-WP-0064): enable cluster consistency sweep schedule Enable the definition in k8s projection and pass activity-core source tags. --- k8s/railiance/20-runtime.yaml | 5 +++-- tests/test_state_hub_context_resolver.py | 4 ++-- 2 files changed, 5 insertions(+), 4 deletions(-) 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, } ]