diff --git a/server/website/website/tasks/async_tasks.py b/server/website/website/tasks/async_tasks.py index b9d0af6..75c0ae4 100644 --- a/server/website/website/tasks/async_tasks.py +++ b/server/website/website/tasks/async_tasks.py @@ -174,6 +174,7 @@ def clean_metric_data(metric_matrix, metric_labels, session): del metric_labels[i] return matrix, metric_labels + def save_execution_time(start_ts, fn, result): end_ts = time.time() exec_time = end_ts - start_ts diff --git a/server/website/website/tasks/periodic_tasks.py b/server/website/website/tasks/periodic_tasks.py index 72ac69c..ca22b19 100644 --- a/server/website/website/tasks/periodic_tasks.py +++ b/server/website/website/tasks/periodic_tasks.py @@ -4,8 +4,8 @@ # Copyright (c) 2017-18, Carnegie Mellon University Database Group # import copy -import numpy as np import time +import numpy as np from pytz import timezone from celery import shared_task @@ -30,6 +30,7 @@ LOG = get_task_logger(__name__) # Only process workload containing this minimum amount of results MIN_WORKLOAD_RESULTS_COUNT = 5 + def save_execution_time(start_ts, fn): end_ts = time.time() exec_time = end_ts - start_ts