From 2e232ce641f970e10687ade1b526b2b6b58926f7 Mon Sep 17 00:00:00 2001 From: Benjamin Tovar Date: Fri, 17 Sep 2021 13:11:07 -0400 Subject: [PATCH] wq: use correct statistic when collecting task execute time execute_cmd_finish and execute_cmd_start measured from submission time, not execution time. --- coffea/processor/work_queue_tools.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/coffea/processor/work_queue_tools.py b/coffea/processor/work_queue_tools.py index e0ad5e0c3..536060050 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: @@ -621,7 +621,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, ) )