Skip to content

EventConsumer hanging due to missing Pydantic model reconstruction in Redis queues #2

@NishantSrivastava81

Description

@NishantSrivastava81

The existing a2a-redis implementations (both RedisStreamsEventQueue and RedisPubSubEventQueue) serialize Pydantic models to JSON correctly but only return raw dictionaries during deserialization. The A2A framework's EventConsumer expects actual Pydantic model instances, not dictionaries.

This causes the A2A framework's EventConsumer to hang indefinitely during event processing. Upon dequeue, only raw Python dictionaries are returned instead of reconstructing the original Pydantic model instances. The A2A framework's EventConsumer.consume_all() method relies on isinstance() checks and attribute access on Pydantic models to determine when to stop consuming events:

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions