1f54acd27488f089f3211c08aef5d9927183d1c6,python/ray/worker.py,,cancel,#Any#Any#,1736

Before Change

    worker.check_connected()

    if not isinstance(object_ref, ray.ObjectRef):
        raise TypeError(
            "ray.cancel() only supported for non-actor object refs. "
            "Got: {}.".format(type(object_ref)))
    return worker.core_worker.cancel_task(object_ref, force)


def _mode(worker=global_worker):

After Change

    worker.check_connected()

    if not isinstance(object_ref, ray.ObjectRef):
        raise TypeError(
            "ray.cancel() only supported for non-actor object refs. "
            f"Got: {type(object_ref)}.")
    return worker.core_worker.cancel_task(object_ref, force)


def _mode(worker=global_worker):

Instances