async def METHOD_NAME(self, session_id: str):
    from .oscar import MutableAPI
    cluster_api = await self._get_cluster_api()
    [address] = await cluster_api.get_supervisors_by_keys([session_id])
    return await MutableAPI.create(session_id, address)