ray.cancel
ray.cancel#
- ray.cancel(object_ref: ray.ObjectRef, *, force: bool = False, recursive: bool = True)[source]#
Cancels a task according to the following conditions.
If the specified task is pending execution, it will not be executed. If the task is currently executing, the behavior depends on the
force
flag. Whenforce=False
, a KeyboardInterrupt will be raised in Python and whenforce=True
, the executing task will immediately exit. If the task is already finished, nothing will happen.Only non-actor tasks can be canceled. Canceled tasks will not be retried (max_retries will not be respected).
Calling ray.get on a canceled task will raise a TaskCancelledError or a WorkerCrashedError if
force=True
.- Parameters
object_ref – ObjectRef returned by the task that should be canceled.
force – Whether to force-kill a running task by killing the worker that is running the task.
recursive – Whether to try to cancel tasks submitted by the task specified.
- Raises
TypeError – This is also raised for actor tasks.
PublicAPI: This API is stable across Ray releases.