The task predict_batch_task should call to MetricPredictionProgress.refresh. This can be donde combining chord and group.