feat(STATE-WP-0064): enable cluster consistency sweep schedule

Enable the definition in k8s projection and pass activity-core source tags.
This commit is contained in:
2026-06-21 21:46:43 +02:00
parent adfd1a9067
commit faf5d60ae8
2 changed files with 5 additions and 4 deletions

View File

@@ -170,10 +170,10 @@ data:
name: "State Hub Consistency Sweep" name: "State Hub Consistency Sweep"
type: activity-definition type: activity-definition
version: "1.0" version: "1.0"
enabled: false enabled: true
owner: custodian owner: custodian
governance: custodian governance: custodian
status: proposed status: active
created: "2026-06-21" created: "2026-06-21"
trigger: trigger:
type: cron type: cron
@@ -186,6 +186,7 @@ data:
required: true required: true
params: params:
max_seconds: 300 max_seconds: 300
source: activity-core
bind_to: context.consistency_sweep_remote_all bind_to: context.consistency_sweep_remote_all
--- ---

View File

@@ -429,7 +429,7 @@ def test_consistency_sweep_remote_all_posts_batch(monkeypatch) -> None:
result = StateHubContextResolver().resolve( result = StateHubContextResolver().resolve(
"consistency_sweep_remote_all", "consistency_sweep_remote_all",
None, None,
{"max_seconds": 300, "required": True}, {"max_seconds": 300, "source": "activity-core", "required": True},
) )
assert result["exit_code"] == 0 assert result["exit_code"] == 0
@@ -437,7 +437,7 @@ def test_consistency_sweep_remote_all_posts_batch(monkeypatch) -> None:
assert calls == [ assert calls == [
{ {
"url": "http://state-hub.test/consistency/sweep/remote-all", "url": "http://state-hub.test/consistency/sweep/remote-all",
"json": {"max_seconds": 300}, "json": {"max_seconds": 300, "source": "activity-core"},
"timeout": 330.0, "timeout": 330.0,
} }
] ]