diff --git a/coffea/processor/work_queue_tools.py b/coffea/processor/work_queue_tools.py index 9374b42e0..ace1d2eb1 100644 --- a/coffea/processor/work_queue_tools.py +++ b/coffea/processor/work_queue_tools.py @@ -241,7 +241,7 @@ def report(self, output_mode, resource_mode): self.resources_measured.memory, self.resources_measured.disk, self.resources_measured.gpus, - (self.execute_cmd_finish - self.execute_cmd_start) / 1e6, + (self.cmd_execution_time) / 1e6, ) if (task_failed or output_mode) and self.std_output: @@ -624,7 +624,7 @@ def _work_queue_processing( task_reports.append( ( len(task), - (task.execute_cmd_finish - task.execute_cmd_start) / 1e6, + (task.cmd_execution_time) / 1e6, task.resources_measured.memory, ) )