drain

AsyncMethod

This is a method of the OutboundDeliveryProtocol class in the protocols module.

Process pending messages. Called on startup to retry unsent messages. Messages are processed oldest-first to maintain order.

Signature

async def drain(sender: Callable[[str, Dict[str, Any]], Awaitable[bool]], limit: Optional[int]) -> tuple[int, int]

Callable

required

Async function that attempts delivery. Should return True on success, False to retry later.

Optional[int]

Optional max messages to process

tuple[int, int]

Tuple of (succeeded, failed) counts

praisonaiagents/gateway/protocols.py at line 1528