9 releases 9 tags

RSS feed

• v1.19.0 9b01b4735d

  Compare

  v1.19.0 — Agent Job Queue & Dispatch Stable

  Gravity Bot released this 2026-02-22 18:06:05 +00:00 | 101 commits to main since this release

  Features

  • Job Queue Infrastructure: NATS JetStream-backed work queue for agent dispatches with durable AGENT_JOBS stream
  • Job Message Producer/Consumer: Publish job requests and pull-based consumption with configurable batch sizes
  • Job Store: Full CRUD operations for job state persistence with PostgreSQL engine_jobs table
  • Job State Machine: Typed state transitions (pending → running → completed/failed/dead) with audit tracking
  • Retry & Backoff: Exponential backoff retry logic with configurable max attempts and dead-letter handling
  • Timeout Enforcement: Per-job timeout with background reaper for stale/stuck jobs
  • Concurrency Limiter: Semaphore-based per-agent-type concurrency control
  • Job Metrics & Logging: Structured logging for queue depth, processing latency, and job lifecycle events
  • REST API: Job submission endpoint (POST /jobs) and job management handler
  • Async Dispatch: Event engine refactored from synchronous CLI dispatch to async job submission
  • Result Events: Job completion results published back to NATS for downstream consumers

  Refactoring

  • Replaced synchronous Claude CLI dispatch with async job submission pipeline

  Tests

  • Unit tests for JetStream job queue (producer, consumer)
  • Unit tests for job store and state machine
  • Unit tests for retry, timeout, and reaper logic
  • Unit tests for concurrency limiter
  • Unit tests for job API handlers
  • End-to-end integration tests for async dispatch pipeline

  Tasks

  • OP#1247: Configure JetStream stream for agent jobs
  • OP#1248: Implement job message producer
  • OP#1249: Implement job message consumer (pull-based)
  • OP#1250: Unit tests for JetStream job queue
  • OP#1251: Create jobs table migration
  • OP#1252: Implement job store CRUD operations
  • OP#1253: Implement job state machine transitions
  • OP#1254: Unit tests for job store and state machine
  • OP#1255: Implement retry logic with exponential backoff
  • OP#1256: Implement job timeout enforcement
  • OP#1257: Unit tests for retry and timeout logic
  • OP#1258: Implement semaphore-based concurrency limiter
  • OP#1259: Add job queue metrics and logging
  • OP#1260: Unit tests for concurrency limiter
  • OP#1261: Implement job REST API handler
  • OP#1262: Add job submission endpoint
  • OP#1263: Unit tests for job API endpoints
  • OP#1264: Refactor engine to submit jobs instead of dispatching synchronously
  • OP#1265: Write dispatch result back to job state
  • OP#1266: End-to-end integration test for async dispatch

  Downloads

  • Source code (ZIP)
    0 downloads
  • Source code (TAR.GZ)
    0 downloads