async def METHOD_NAME(self, event_type, source_id, ttl) -> StorageRecords:
    """
    Session cache
    """
    if ttl > 0:
        return await MemoryCache.cache(
            self.event_destination_cache(),
            f"{event_type}-{source_id}",
            ttl,
            destination_db.load_event_destinations,
            True,
            event_type,
            source_id
        )
    return await destination_db.load_event_destinations(event_type=event_type, source_id=source_id)