ray.tune.stopper.Stopper#

class ray.tune.stopper.Stopper[source]#

Bases: ABC

Base class for implementing a Tune experiment stopper.

Allows users to implement experiment-level stopping via stop_all. By default, this class does not stop any trials. Subclasses need to implement __call__ and stop_all.

Examples

>>> import time
>>> from ray import train, tune
>>> from ray.tune import Stopper
>>>
>>> class TimeStopper(Stopper):
...     def __init__(self):
...         self._start = time.time()
...         self._deadline = 2  # Stop all trials after 2 seconds
...
...     def __call__(self, trial_id, result):
...         return False
...
...     def stop_all(self):
...         return time.time() - self._start > self._deadline
...
>>> def train_fn(config):
...     for i in range(100):
...         time.sleep(1)
...         train.report({"iter": i})
...
>>> tuner = tune.Tuner(
...     train_fn,
...     tune_config=tune.TuneConfig(num_samples=2),
...     run_config=train.RunConfig(stop=TimeStopper()),
... )
>>> print("[ignore]"); result_grid = tuner.fit()  
[ignore]...

Methods

`__init__`
`stop_all`	Returns true if the experiment should be terminated.