async def METHOD_NAME(
    self, subtask_ids: List[str], kill_timeout: Union[float, int] = None
):
    """
    Cancel pending and running subtasks.
    Parameters
    ----------
    subtask_ids
        ids of subtasks to cancel
    kill_timeout
        timeout seconds to kill actor process forcibly
    """
    await self._manager_ref.METHOD_NAME(subtask_ids, kill_timeout=kill_timeout)