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

ORCH-108: BullMQ task queue #243

New Issue
Closed
opened 2026-02-02 21:02:33 +00:00 by jason.woltje · 0 comments
jason.woltje commented 2026-02-02 21:02:33 +00:00
Owner
Copy Link

Implement task queue with priority and retry logic using BullMQ on Valkey.

Implementation Complete

Features Implemented

  • BullMQ queue backed by Valkey
  • Priority-based task ordering (1-10)
  • Retry logic with exponential backoff
  • Queue worker to process tasks
  • Queue monitoring (pending, active, completed, failed counts)
  • QueuedTask interface matching requirements
  • NestJS service with dependency injection
  • Integration with ValkeyService for connection
  • Comprehensive unit tests
  • README documentation

Files Created

  • src/queue/types/queue.types.ts - Type definitions
  • src/queue/queue.service.ts - Main service implementation
  • src/queue/queue.service.spec.ts - Unit tests
  • src/queue/queue.module.ts - NestJS module
  • src/queue/index.ts - Public exports
  • src/queue/README.md - Module documentation

Configuration

All configuration via ConfigService

Testing

  • Unit tests: 10 tests passing
  • TypeScript: No errors
  • Tests cover pure functions and business logic

Events Published

  • task.queued - Task added to queue
  • task.processing - Task started processing
  • task.retry - Task retrying after failure
  • task.completed - Task completed successfully
  • task.failed - Task failed permanently

Dependencies: ORCH-107 (ValkeyService) Complete

Implement task queue with priority and retry logic using BullMQ on Valkey. ## Implementation Complete ### Features Implemented - BullMQ queue backed by Valkey - Priority-based task ordering (1-10) - Retry logic with exponential backoff - Queue worker to process tasks - Queue monitoring (pending, active, completed, failed counts) - QueuedTask interface matching requirements - NestJS service with dependency injection - Integration with ValkeyService for connection - Comprehensive unit tests - README documentation ### Files Created - src/queue/types/queue.types.ts - Type definitions - src/queue/queue.service.ts - Main service implementation - src/queue/queue.service.spec.ts - Unit tests - src/queue/queue.module.ts - NestJS module - src/queue/index.ts - Public exports - src/queue/README.md - Module documentation ### Configuration All configuration via ConfigService ### Testing - Unit tests: 10 tests passing - TypeScript: No errors - Tests cover pure functions and business logic ### Events Published - task.queued - Task added to queue - task.processing - Task started processing - task.retry - Task retrying after failure - task.completed - Task completed successfully - task.failed - Task failed permanently Dependencies: ORCH-107 (ValkeyService) Complete
jason.woltje added this to the M6-AgentOrchestration (0.0.6) milestone 2026-02-02 21:02:33 +00:00
jason.woltje added the orchestrator label 2026-02-02 21:02:33 +00:00
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 M6-AgentOrchestration (0.0.6)
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#243
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?