def METHOD_NAME(self, retry: bool = False):
    self._finished = datetime.now(timezone.utc)
    if self._handle:
        (handle, queue) = self._handle
        loop = asyncio.get_event_loop()
        if retry:
            loop.create_task(queue.reschedule(handle))
        else:
            loop.create_task(queue.mark_done(handle))