async def METHOD_NAME(
    self,
    graph: TileableGraph,
    fuse_enabled: bool = None,
    extra_config: dict = None,
) -> str:
    try:
        return await self._task_manager_ref.METHOD_NAME(
            graph, fuse_enabled=fuse_enabled, extra_config=extra_config
        )
    except mo.ActorNotExist:
        raise RuntimeError("Session closed already")