diff options
Diffstat (limited to 'storperf/db/job_db.py')
| -rw-r--r-- | storperf/db/job_db.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/storperf/db/job_db.py b/storperf/db/job_db.py index 57c82cb..8aa4c11 100644 --- a/storperf/db/job_db.py +++ b/storperf/db/job_db.py @@ -76,11 +76,13 @@ class JobDB(object): db.commit() db.close() - def start_workload(self, workload_name): + def start_workload(self, workload): """ Records the start time for the given workload """ + workload_name = workload.fullname + if (self.job_id is None): self.create_job_id() @@ -122,13 +124,15 @@ class JobDB(object): db.commit() db.close() - def end_workload(self, workload_name): + def end_workload(self, workload): """ Records the end time for the given workload """ if (self.job_id is None): self.create_job_id() + workload_name = workload.fullname + with db_mutex: db = sqlite3.connect(JobDB.db_name) @@ -174,8 +178,6 @@ class JobDB(object): workload_prefix = workload_prefix + "%" - stats = () - start_time = str(calendar.timegm(time.gmtime())) end_time = "0" |