chia-blockchain/chia/util/safe_cancel_task.py

import asyncio
from typing import Optional


def cancel_task_safe(task: Optional[asyncio.Task], log=None):
    if task is not None:
        try:
            task.cancel()
        except Exception as e:
            if log is not None:
                log.error(f"Error while canceling task.{e} {task}")