Skip to content

[Feature] Redis Streams Integration for Status Events #44

@yedidyakfir

Description

@yedidyakfir

Description

Add Redis Streams support for durable status change events.

Blocked by: #40, #42, #43


Tasks

  • Research Redis Streams consumer groups API
  • Design event schema: {signature_key, old_status, new_status, timestamp, signature_type}
  • Implement stream publishing on TaskSignature.done() and TaskSignature.failed()
  • Create consumer group utilities for the external service
  • Add integration tests for stream reliability

Key Files

  • /mageflow/signature/model.py
  • /mageflow/signature/status.py

Metadata

Metadata

Assignees

No one assigned

    Labels

    featureNew functionalityphase: 2Phase 2 - Infrastructurepriority: highHigh priority feature

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions