diff options
Diffstat (limited to 'storperf/db/job_db.py')
| -rw-r--r-- | storperf/db/job_db.py | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/storperf/db/job_db.py b/storperf/db/job_db.py index 3d66be8..05160ec 100644 --- a/storperf/db/job_db.py +++ b/storperf/db/job_db.py @@ -7,11 +7,11 @@ # http://www.apache.org/licenses/LICENSE-2.0 ############################################################################## -from sqlite3 import OperationalError -from threading import Lock import calendar import logging +from sqlite3 import OperationalError import sqlite3 +from threading import Lock import time import uuid @@ -54,6 +54,14 @@ class JobDB(object): except OperationalError: self.logger.debug("Job params table exists") + try: + cursor.execute('''CREATE TABLE job_summary + (job_id text, + summary text)''') + self.logger.debug("Created job table") + except OperationalError: + self.logger.debug("Job table exists") + cursor.execute('SELECT * FROM jobs') cursor.execute('SELECT * FROM job_params') db.commit() |