coulomb/activity-core
2
0
Fork 0
generated from coulomb/repo-seed
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
51 Commits 2 Branches 0 Tags
96e754dd2dbff1429a83f2e489232c2a17e82441
Commit Graph

51 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
tegwick
96e754dd2d chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 22:19:19 +01:00
tegwick
b21dfbdada chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 14:00:12 +01:00
tegwick
acc913050e chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 13:43:38 +01:00
tegwick
7df22516d5 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 13:26:40 +01:00
tegwick
5408caa045 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 12:54:37 +01:00
tegwick
45e4b6265f chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 09:52:45 +01:00
tegwick
ffcda0b07e chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 09:36:04 +01:00
tegwick
459628cd73 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 09:17:51 +01:00
tegwick
9977884e51 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 05:00:11 +01:00
tegwick
8fa6072bac chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 04:44:10 +01:00
tegwick
28ff5e3073 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 04:28:11 +01:00
tegwick
9270a46a60 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 04:12:19 +01:00
tegwick
657e30ed61 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 03:56:11 +01:00
tegwick
328a4bd435 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 03:40:11 +01:00
tegwick
fef9cddfee chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 03:24:10 +01:00
tegwick
70a384c6e2 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 03:08:37 +01:00
tegwick
6ef60f4448 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 02:52:50 +01:00
tegwick
cabe9b34ab chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 02:37:13 +01:00
tegwick
c8e20eb3ee chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 02:21:32 +01:00
tegwick
230be8899d chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 02:05:21 +01:00
tegwick
284927d550 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 01:49:02 +01:00
tegwick
dddf7148df chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 01:34:08 +01:00
tegwick
a62116ed68 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 01:18:09 +01:00
tegwick
6ef34b4e0d feat(e2e): add run-on-host.sh for automated cron on railiance01 
CUST-WP-0028-T06:
- e2e/run-on-host.sh: standalone script for native execution on railiance01
  (no SSH from workstation). git pull → compose up → health wait →
  test_full_flow.py → compose down → report to state-hub via ops-bridge.

Install via: make e2e-cron-install REPO=activity-core  (from ~/the-custodian)

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-27 01:02:21 +01:00
tegwick
a57eee51f4 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 01:01:46 +01:00
tegwick
8d8a353901 feat(e2e): add e2e contract and test script (closes T21) 
CUST-WP-0028-T03/T04:
- e2e/e2e.yml: declares stack (docker-compose.dev.yml), Temporal UI
  health check, test command
- e2e/tests/test_full_flow.py: automates WP-0001 T21 — seeds DB, starts
  workers, triggers RunActivityWorkflow, polls completion, asserts
  ActivityRun + TaskInstances written to DB

Run via: make e2e REPO=activity-core  (from ~/the-custodian)

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-27 00:52:47 +01:00
tegwick
d6fcb1398a chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 00:47:32 +01:00
tegwick
1df1ebaf99 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-27:
  - update .custodian-brief.md for activity-core
 2026-03-27 00:44:25 +01:00
tegwick
22f9c03474 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-26:
  - update .custodian-brief.md for activity-core
 2026-03-27 00:20:25 +01:00
tegwick
9c8b123457 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-26:
  - update .custodian-brief.md for activity-core
 2026-03-27 00:20:25 +01:00
Bernd Worsch
34aa70cbd9 feat(workflows): TaskExecutorWorkflow stub + wire worker — T19/T20 
activities.py — persist_task_instance (new):
  Idempotent INSERT ... ON CONFLICT (id) DO NOTHING on task_instances.
  task_id passed in from workflow (derived from workflow_id via uuid5).
  Registered on task-execution-tq.

workflows.py — TaskExecutorWorkflow (T19):
  Derives stable task_id = uuid5(NAMESPACE_URL, workflow_id).
  Calls persist_task_instance → status=done, returns immediately.
  Real execution logic to replace stub in a later workstream.

worker.py — T20:
  Registers persist_task_instance on task-execution-tq Worker.
  Both queues fully wired: orchestrator-tq and task-execution-tq.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 22:30:50 +00:00
Bernd Worsch
da7de6ea3b feat(workflows): implement RunActivityWorkflow — T18 
workflows.py — RunActivityWorkflow:
  1. load_activity_definition(activity_id)
  2. resolve_context(context_sources)
  3. evaluate_templates (pure, called in-workflow)
  4. log_run({run_id, ...}) — run_id = uuid5(NAMESPACE_URL, activity_id:trigger_key)
  5. start_child_workflow(TaskExecutorWorkflow, ...) per task spec
     ABANDON parent-close policy (fire-and-forget)
  Returns {"run_id": str, "tasks_spawned": int}

activities.py — log_run updated:
  - now accepts run_id in run_payload (deterministic, passed from workflow)
  - uses pg INSERT ... ON CONFLICT (run_id) DO NOTHING for idempotency

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 22:25:19 +00:00
Bernd Worsch
068780224e feat(activities): implement log_run — T17 
Inserts an ActivityRun row via the shared session factory.
Accepts run_payload dict with activity_id, scheduled_for (ISO-8601 or
None), context_snapshot, tasks_spawned, version_used.
Returns run_id as a str UUID.
fired_at is set server-side to now(UTC).

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 22:19:12 +00:00
tegwick
6e24ef9d3b chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-26:
  - update .custodian-brief.md for activity-core
 2026-03-26 23:11:20 +01:00
tegwick
62df10cc6a chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-26:
  - update .custodian-brief.md for activity-core
 2026-03-26 23:11:20 +01:00
Bernd Worsch
bac3efee89 feat(activities): resolve_context stub + evaluate_templates — T15/T16 
activities.py — resolve_context (T15):
  - dispatches on source.type: 'static' returns config["value"]
  - 'http_get' / 'db_query' raise ApplicationError(non_retryable=True)
  - unknown types raise ApplicationError(non_retryable=True)

template_engine.py — evaluate_templates (T16, pure function):
  - evaluates optional condition expressions against context snapshot
    (restricted eval, no builtins)
  - interpolates {context.<name>.<key>} placeholders via str.format_map
  - returns list[{task_type, params}] with falsy-condition rows omitted

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 22:06:09 +00:00
Bernd Worsch
5e4dc6c946 feat(activities): implement load_activity_definition — T14 
activities.py:
- init_session_factory(url): module-level async_sessionmaker init,
  called once from worker.py before workers start
- load_activity_definition(activity_id): queries activity_definitions
  by UUID, returns JSON-serialisable dict; raises ApplicationError
  (non_retryable=True) if row not found

worker.py:
- reads ACTCORE_DB_URL at startup, fails fast if missing
- calls init_session_factory() before connecting to Temporal

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 22:02:15 +00:00
Bernd Worsch
21edc313db feat(worker): scaffold activities, workflows, worker entrypoint — T13 
src/activity_core/activities.py:
  - load_activity_definition, resolve_context, log_run — @activity.defn
    stubs (raise NotImplementedError, bodies in T14–T17)

src/activity_core/workflows.py:
  - RunActivityWorkflow (orchestrator-tq) — @workflow.defn stub (T18)
  - TaskExecutorWorkflow (task-execution-tq) — @workflow.defn stub (T19)

src/activity_core/worker.py:
  - Connects to Temporal via TEMPORAL_HOST / TEMPORAL_NAMESPACE env vars
  - Spawns two Workers: orchestrator-tq and task-execution-tq
  - Runs until cancelled (python -m activity_core.worker)

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 21:57:56 +00:00
Bernd Worsch
027e41dbc0 feat(db): add dev seed script for ActivityDefinition — T12 
src/activity_core/seed.py: inserts one example ActivityDefinition
('example-heartbeat', cron every minute, static context source,
log_message task template). Idempotent — skips by name on re-run.

Run with:
  ACTCORE_DB_URL=postgresql+asyncpg://actcore:actcore@localhost:5433/actcore \
      python -m activity_core.seed

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 21:53:59 +00:00
Bernd Worsch
cb7cf3bc8c feat(db): ORM models + Alembic migrations 0001–0003 — T09/T10/T11 
SQLAlchemy ORM (src/activity_core/orm.py):
  - ActivityDefinition, ActivityRun, TaskInstance mapped to Base.metadata
  - Wired into migrations/env.py for autogenerate support

Migrations (chained 0001 → 0002 → 0003):
  - 0001: activity_definitions (id, name, enabled, trigger_type,
          trigger_config JSONB, context_sources JSONB, task_templates JSONB,
          dedupe_key_strategy, version, created_at, updated_at)
  - 0002: activity_runs (run_id, activity_id FK→activity_definitions,
          scheduled_for, fired_at, context_snapshot JSONB, tasks_spawned,
          version_used) + index on activity_id
  - 0003: task_instances (id, run_id FK→activity_runs CASCADE,
          type, params JSONB, status, created_at) + index on run_id

Apply with: ACTCORE_DB_URL=... alembic upgrade head

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 21:51:01 +00:00
Bernd Worsch
f55f497107 feat(db): init Alembic (async) + SQLAlchemy declarative base — T08 
- alembic init -t async migrations
- alembic.ini: dev fallback URL postgresql+asyncpg://…:5433/actcore;
  ACTCORE_DB_URL env var overrides at runtime; src/ added to sys.path
- migrations/env.py: reads ACTCORE_DB_URL, wires target_metadata to Base.metadata
- src/activity_core/db.py: DeclarativeBase subclass + make_engine() helper

Tool choice: Alembic + SQLAlchemy[asyncio] (already declared in pyproject.toml).
Migrations run with: ACTCORE_DB_URL=... alembic upgrade head

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 21:45:40 +00:00
Bernd Worsch
c39c32abcd fix(docker): use fully-qualified docker.io image refs; mark T07 done 
Prefix all image names with docker.io/ to avoid registry ambiguity
on hosts where containerd/Podman default to docker.io but the pull
fails without an explicit registry prefix.

Also marks T07 (smoke-test Temporal cluster and UI) as done in the
workplan now that the stack boots cleanly.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 21:26:33 +00:00
tegwick
045461282d chore: add .custodian-brief.md protocol and unblock T07 
- CLAUDE.md: read .custodian-brief.md as Step 1 (offline-safe orientation
  before MCP call); matches pattern now standard across all domain repos
- T07 (Smoke test Temporal): remove stale Docker TLS blocking_reason;
  status → todo (WSL2 MTU issue resolved by implementing on CoulombCore)

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-26 21:03:56 +01:00
tegwick
f9ca8b2446 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-26:
  - update .custodian-brief.md for activity-core
 2026-03-26 20:53:57 +01:00
tegwick
416c4c68d6 chore(consistency): sync task status from DB [auto] 
Updated by fix-consistency on 2026-03-26:
  - update .custodian-brief.md for activity-core
 2026-03-26 18:04:07 +01:00
tegwick
cf6eb15485 updated SCOPE.md file 2026-03-19 21:26:53 +01:00
tegwick
381219c3d5 docs: add SCOPE.md for rapid orientation 
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-17 23:10:42 +01:00
tegwick
2dc8066f87 docs: add agent inbox check to session protocol 
Check get_messages(to_agent="activity-core") at session start per CUST-WP-0015.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-16 02:56:06 +01:00
tegwick
ca06a41bac feat(claude): add goal_guidance handling to session brief protocol 
Surface needs_workplan and alignment_warnings from get_domain_summary()
in the session brief. Repo goal with no workplan is highest priority
action; misaligned workstreams are flagged but not blocked.

Follows CUST-WP-0010 goal tracking rollout.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-11 23:07:12 +01:00
tegwick
6f9132314f Add project scaffold: contracts, schemas, docker-compose, workplans 
Phase 0 contracts (event envelope, ActivityDefinition, idempotency doc,
naming conventions) and Phase 1 Temporal cluster setup (docker-compose.dev.yml,
Temporal dynamic config) are complete. Includes Pydantic models, JSON schemas,
wiki architecture docs, and ADR-001 workplan files for both workstreams.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-03-04 22:45:40 +01:00