async def METHOD_NAME(
    self, client_connection_id: str = None, tag_filter: dict = None
) -> Sequence[RouteRecord]:
    """Fetch all routes associated with the current connection.
    Args:
        client_connection_id: The ID of the connection record
        tag_filter: An optional dictionary of tag filters
    Returns:
        A sequence of route records found by the query
    """
    # Routing protocol acts only as Server, filter out all client records
    filters = {"role": RouteRecord.ROLE_SERVER}
    if client_connection_id:
        filters["connection_id"] = client_connection_id
    if tag_filter:
        for key in ("recipient_key",):
            if key not in tag_filter:
                continue
            val = tag_filter[key]
            if isinstance(val, str):
                filters[key] = val
            elif isinstance(val, list):
                filters[key] = {"$in": val}
            else:
                raise RoutingManagerError(
                    "Unsupported tag filter: '{}' = {}".format(key, val)
                )
    async with self._profile.session() as session:
        results = await RouteRecord.query(session, tag_filter=filters)
    return results