in src/chug/common/types.py [0:0]
def set_interval(self, interval):
if self.shared_interval is not None:
self.shared_interval.set_value(interval)
if self.sampler is not None and isinstance(self.sampler, DistributedSampler):
self.sampler.set_epoch(interval)