coulomb/coordination-engine
4
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
Framework for digital coordination as goal-driven communication
24 commits 1 branch 0 tags 349 KiB
Find a file
Exact
tegwick 3fc4d67cf1
All checks were successful
CI Smoke / host-smoke (push) Successful in 0s
Details
CI Smoke / container-smoke (push) Successful in 1s
Details
docs: align TAMQ worker adapter contract 
Assistant: codex
Assistant-Model: gpt-5.6-sol
Assistant-Session: 01a03397-4d51-7fd1-8ff2-946eb22ea2bc
2026-08-26 08:10:54 +02:00
.claude/rules docs: workplan-first agent guidance prose (CUST-WP-0055 T04 batch 5) 2026-07-08 19:51:14 +02:00
.forgejo/workflows Add Forgejo CI smoke workflow (enablement template) 2026-07-08 12:30:31 +02:00
history Seeded repo with intent and specs 2026-06-01 23:59:23 +02:00
registry Add registry/NO_CAPABILITIES.md (reuse-surface REUSE-WP-0017-T03) 2026-07-06 18:50:37 +02:00
spec docs: align TAMQ worker adapter contract 2026-08-26 08:10:54 +02:00
workplans chore(registrar): assign State Hub identifiers 2026-08-25 17:44:54 +02:00
.custodian-brief.md chore(consistency): sync task status from DB [auto] 2026-08-25 17:44:53 +02:00
.gitignore Initial commit 2026-06-01 18:21:12 +00:00
.repo-classification.yaml Human-review .repo-classification.yaml (CUST-WP-0050 follow-up) 2026-06-22 17:56:16 +02:00
AGENTS.md docs(agents): repoint remote State Hub URL to the in-cluster address 2026-08-25 00:20:48 +02:00
CLAUDE.md Add State Hub bootstrap workplan and agent integration files 2026-06-22 21:44:35 +02:00
INTENT.md Seeded repo with intent and specs 2026-06-01 23:59:23 +02:00
LICENSE Adopt Target Revenue Source License V1C1 (org-wide preliminary rollout) 2026-07-30 00:01:31 +02:00
README.md docs: align TAMQ worker adapter contract 2026-08-26 08:10:54 +02:00
SCOPE.md chore: commit work in progress before registrar reconciliation 2026-08-25 17:44:39 +02:00
WORK-RECORDS.md chore: commit work in progress before registrar reconciliation 2026-08-25 17:44:39 +02:00

README.md

Coordination Engine

Framework for digital coordination as goal-driven communication.

TAMQ worker-session adapter

Coordination-engine owns trigger observation, actionability and safety policy, coordination leases, checkpoints, and State Hub receipts. TAMQ separately owns local repository sessions, durable messages, terminal delivery attempts, and acknowledgement state.

The implemented async boundary is provided by tamq.client:

from tamq.client import CoordinationEngineAdapter, WakeRequest

receipt = await CoordinationEngineAdapter().wake(
    WakeRequest(
        lease_id="lease-123",
        trigger_id="task-456:r7",
        target_repo="audit-core",
        prompt="Resume the actionable task and publish a checkpoint.",
    )
)

The coordination lease ID makes wake admission idempotent. An exact live TAMQ endpoint is required; the adapter will not choose between multiple sessions or start an agent implicitly. Transport states (pending, awaiting_ack, injected, acknowledged, failed) are receipts, not workflow completion. See spec/worker-coordination-service-v0.1.md and the canonical tmux-amq/spec/coordination-engine-adapter-v0.1.md contract.