Fix experiment group check finished
@@ -64,7 +64,8 @@ def stop_group_experiments(experiment_group_id, pending, message=None):
max_retries=None)
def check_group_finished(self, experiment_group_id):
experiment_group = get_valid_experiment_group(experiment_group_id=experiment_group_id)
- if not experiment_group.non_done_experiments.exists():
+ if experiment_group.non_done_experiments.exists():
self.retry(countdown=Intervals.EXPERIMENTS_SCHEDULER)
+ return
experiment_group.set_status(status=ExperimentGroupLifeCycle.SUCCEEDED)
