From 5f06b3d019447444fe0f71b13139112636bf8ad8 Mon Sep 17 00:00:00 2001 From: Tyler Gu Date: Mon, 20 Nov 2023 09:56:39 -0600 Subject: [PATCH] Fix Signed-off-by: Tyler Gu --- performance_measurement/measure_performance.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/performance_measurement/measure_performance.py b/performance_measurement/measure_performance.py index 37e3c7aa4..507d1f11e 100644 --- a/performance_measurement/measure_performance.py +++ b/performance_measurement/measure_performance.py @@ -5,15 +5,15 @@ import logging import os import sys -from datetime import datetime import threading +from datetime import datetime from typing import Callable import yaml -from measure_runner import ConditionFuncType, MeasurementRunner from fluent_inputs import FluentInputGenerator -from stats_watch import WatchStats +from measure_runner import MeasurementRunner from rabbitmq_inputs import RabbitMQInputGenerator +from stats_watch import WatchStats from zk_inputs import ZooKeeperInputGenerator sys.path.insert(0, os.path.abspath( @@ -98,7 +98,7 @@ def test_normal( single_operation_trial_dir = f"{workdir}/trial-single-operation" os.makedirs(single_operation_trial_dir, exist_ok=True) - control_plane_stats_dir = os.path.join(trial_dir, "control_plane_stats") + control_plane_stats_dir = os.path.join(single_operation_trial_dir, "control_plane_stats") os.makedirs(control_plane_stats_dir, exist_ok=True) gen = 0 for workload in workloads: