diff --git a/autosubmit/experiment/statistics.py b/autosubmit/experiment/statistics.py index 72bd5a4ff1cf0be5bafacfcbead047bfaf69f0f6..cd988b644e5a3c402ee1a11b79165ad50f713f65 100644 --- a/autosubmit/experiment/statistics.py +++ b/autosubmit/experiment/statistics.py @@ -99,8 +99,8 @@ class ExperimentStats(object): def _calculate_stats(self): for i, job in enumerate(self._jobs_list): - processors = job.processors last_retrials = job.get_last_retrials() + processors = job.total_processors for retrial in last_retrials: if Job.is_a_completed_retrial(retrial): self._queued[i] += retrial[1] - retrial[0] @@ -120,7 +120,7 @@ class ExperimentStats(object): self._total_jobs_run += len(last_retrials) self._total_jobs_failed += self.failed_jobs[i] self._threshold = max(self._threshold, job.total_wallclock) - self._expected_cpu_consumption += job.total_wallclock * int(job.total_processors) + self._expected_cpu_consumption += job.total_wallclock * int(processors) self._expected_real_consumption += job.total_wallclock self._total_queueing_time += self._queued[i]