def _make_progress_tracker(self, target_batch_size: int, **kwargs) -> ProgressTracker:
    return ProgressTracker(dht=self.dht, prefix=self.run_id, target_batch_size=target_batch_size, client_mode=self.client_mode, status_loglevel=self.status_loglevel, start=True, **kwargs)
def _make_progress_tracker(self, target_batch_size: int, **kwargs) -> ProgressTracker:
    return ProgressTracker(dht=self.dht, prefix=self.run_id, target_batch_size=target_batch_size, client_mode=self.client_mode, status_loglevel=self.status_loglevel, start=True, **kwargs)