Skip to content

[Feature] External Orchestration Service #47

@yedidyakfir

Description

@yedidyakfir

Description

Create the external service that consumes status events and triggers callbacks.

Blocked by: #44, #45, #46


Components

  1. Event Consumer: Redis Streams consumer with consumer group
  2. Event Processor: Idempotent callback activation
  3. Recovery Handler: Startup scan for incomplete activations
  4. Dead Letter Handler: Failed event management
  5. Health Check: Monitoring endpoint

Tech Stack

  • Async Python (asyncio)
  • Rapyer for Redis models
  • Redis Streams for events

Tasks

  • Set up service scaffold
  • Implement event consumer loop
  • Implement idempotent event processing
  • Add startup recovery scan
  • Add dead letter queue handling
  • Add health check and metrics
  • Create Dockerfile

Metadata

Metadata

Assignees

No one assigned

    Labels

    featureNew functionalityphase: 3Phase 3 - External Servicepriority: highHigh priority feature

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions