mosaic/stack
1
0
Fork 0
Code Issues 10 Pull Requests Actions Packages Projects Releases 2 Wiki Activity

Install mosaicstack-telemetry in Coordinator #370

New Issue
Closed
opened 2026-02-15 05:28:05 +00:00 by jason.woltje · 1 comment
jason.woltje commented 2026-02-15 05:28:05 +00:00
Owner
Copy Link

Summary

Add the mosaicstack-telemetry Python SDK to apps/coordinator so the coordinator can track task completions it dispatches to coding harnesses.

Requirements

Package Installation

  • Install mosaicstack-telemetry from Gitea PyPI registry
  • Add to pyproject.toml dependencies
  • Configure pip index URL: https://git.mosaicstack.dev/api/packages/mosaic/pypi/simple/

Integration Pattern (async lifespan)

from mosaicstack_telemetry import TelemetryClient, TelemetryConfig

@asynccontextmanager
async def lifespan(app: FastAPI):
    config = TelemetryConfig()  # Reads from env vars automatically
    async with TelemetryClient(config) as client:
        app.state.telemetry = client
        await client.start_async()
        yield
        await client.stop_async()

app = FastAPI(lifespan=lifespan)

Environment Variables (auto-read by Python SDK)

MOSAIC_TELEMETRY_ENABLED=true
MOSAIC_TELEMETRY_SERVER_URL=https://tel-api.mosaicstack.dev
MOSAIC_TELEMETRY_API_KEY=<64-char hex>
MOSAIC_TELEMETRY_INSTANCE_ID=<uuid>

Key SDK Details

  • Dual sync/async support (use async for coordinator)
  • Uses httpx.AsyncClient for HTTP, pydantic for validation
  • Thread-safe event queue, async context manager
  • EventBuilder with fluent API for constructing events
  • Never throws — errors logged via logging.getLogger("mosaicstack_telemetry")

What the Coordinator Tracks

The coordinator dispatches tasks to coding harnesses (Claude Code, Codex CLI, OpenCode). After each task completes, it should build a TaskCompletionEvent capturing:

  • Which harness was used
  • Which model/provider
  • Task duration
  • Token usage (from harness output)
  • Quality gate results (build, lint, test, typecheck, security)
  • Outcome (success/failure/partial/timeout)
  • Retry count
  • Context compactions/rotations

Acceptance Criteria

  • Package installed and importable
  • Telemetry client starts/stops with coordinator lifecycle
  • Async context manager for clean shutdown
  • Disabled mode works (no HTTP calls)
  • Unit tests for initialization
## Summary Add the `mosaicstack-telemetry` Python SDK to `apps/coordinator` so the coordinator can track task completions it dispatches to coding harnesses. ## Requirements ### Package Installation - Install `mosaicstack-telemetry` from Gitea PyPI registry - Add to `pyproject.toml` dependencies - Configure pip index URL: `https://git.mosaicstack.dev/api/packages/mosaic/pypi/simple/` ### Integration Pattern (async lifespan) ```python from mosaicstack_telemetry import TelemetryClient, TelemetryConfig @asynccontextmanager async def lifespan(app: FastAPI): config = TelemetryConfig() # Reads from env vars automatically async with TelemetryClient(config) as client: app.state.telemetry = client await client.start_async() yield await client.stop_async() app = FastAPI(lifespan=lifespan) ``` ### Environment Variables (auto-read by Python SDK) ``` MOSAIC_TELEMETRY_ENABLED=true MOSAIC_TELEMETRY_SERVER_URL=https://tel-api.mosaicstack.dev MOSAIC_TELEMETRY_API_KEY=<64-char hex> MOSAIC_TELEMETRY_INSTANCE_ID=<uuid> ``` ### Key SDK Details - Dual sync/async support (use async for coordinator) - Uses `httpx.AsyncClient` for HTTP, `pydantic` for validation - Thread-safe event queue, async context manager - `EventBuilder` with fluent API for constructing events - Never throws — errors logged via `logging.getLogger("mosaicstack_telemetry")` ### What the Coordinator Tracks The coordinator dispatches tasks to coding harnesses (Claude Code, Codex CLI, OpenCode). After each task completes, it should build a `TaskCompletionEvent` capturing: - Which harness was used - Which model/provider - Task duration - Token usage (from harness output) - Quality gate results (build, lint, test, typecheck, security) - Outcome (success/failure/partial/timeout) - Retry count - Context compactions/rotations ## Acceptance Criteria - [ ] Package installed and importable - [ ] Telemetry client starts/stops with coordinator lifecycle - [ ] Async context manager for clean shutdown - [ ] Disabled mode works (no HTTP calls) - [ ] Unit tests for initialization
jason.woltje added the orchestrator label 2026-02-15 05:28:05 +00:00
jason.woltje added this to the M10-Telemetry (0.0.10) milestone 2026-02-15 05:31:19 +00:00
jason.woltje commented 2026-02-15 08:05:00 +00:00
Author
Owner
Copy Link

Completed in commit 83d0cbe on feature/m10-telemetry. Installed mosaicstack-telemetry in coordinator, integrated TelemetryClient into FastAPI lifespan, created mosaic_telemetry.py helpers. 28 unit tests.

Completed in commit 83d0cbe on feature/m10-telemetry. Installed mosaicstack-telemetry in coordinator, integrated TelemetryClient into FastAPI lifespan, created mosaic_telemetry.py helpers. 28 unit tests.
Sign in to join this conversation.
No Branch/Tag Specified
Branches Tags
Labels
Clear labels
ai
AI/LLM integration
 api
Backend/API work
 api
auth
Authentication
 database
database
Database/schema work
 devops
Docker/deployment
 docs
Documentation
 frontend
graph
knowledge-module
migration
Data migration
 orchestrator
Orchestrator service (apps/orchestrator/)
 p0
Critical priority
 p1
High priority
 p2
Medium priority
 p3
Low priority
 performance
Performance work
 phase-1
phase-2
phase-3
phase-4
phase-5
plugin
MoltBot plugin work
 search
security
Security-related
 setup
Initial setup
 testing
Testing/QA
 web
Frontend work
No Label orchestrator
Milestone
No items
No Milestone M10-Telemetry (0.0.10)
Projects
Clear projects
No project
Assignees
Clear assignees
jason.woltje
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: mosaic/stack#370
Delete Branch "%!s()"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?