Skip to content

message_queues#

Message queue module.

BaseMessageQueue #

Bases: BaseModel, AbstractMessageQueue

Source code in llama_deploy/message_queues/base.py 
119
120
121
122
123
class BaseMessageQueue(BaseModel, AbstractMessageQueue):
    model_config = ConfigDict(arbitrary_types_allowed=True)

    def __init__(self, *args: Any, **kwargs: Any) -> None:
        super().__init__(*args, **kwargs)