diff options
Diffstat (limited to 'lorrycontroller/statedb.py')
| -rw-r--r-- | lorrycontroller/statedb.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/lorrycontroller/statedb.py b/lorrycontroller/statedb.py index 7a26098..7f537f3 100644 --- a/lorrycontroller/statedb.py +++ b/lorrycontroller/statedb.py @@ -149,7 +149,7 @@ class StateDB(object): # Stupid table we can always write to to trigger the start of # a transaction. c.execute('CREATE TABLE stupid (value INT)') - + # Done. self._conn.commit() logging.debug('Finished initialising tables in STATEDB') @@ -240,7 +240,7 @@ class StateDB(object): prefixmap=None, ignore=None): logging.debug( 'StateDB.add_trove(%r,%r,%r,%r,%r,%r) called', - trovehost, lorry_interval, lorry_timeout, ls_interval, + trovehost, lorry_interval, lorry_timeout, ls_interval, prefixmap, ignore) assert trovehost is not None @@ -264,7 +264,7 @@ class StateDB(object): 'prefixmap, ignore) ' 'VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)', (trovehost, protocol, username, password, - lorry_interval, lorry_timeout, ls_interval, 0, + lorry_interval, lorry_timeout, ls_interval, 0, prefixmap, ignore)) else: c = self.get_cursor() @@ -273,7 +273,7 @@ class StateDB(object): 'SET lorry_interval=?, lorry_timeout=?, ls_interval=?, ' 'prefixmap=?, ignore=?, protocol=? ' 'WHERE trovehost IS ?', - (lorry_interval, lorry_timeout, ls_interval, prefixmap, + (lorry_interval, lorry_timeout, ls_interval, prefixmap, ignore, protocol, trovehost)) def remove_trove(self, trovehost): @@ -603,7 +603,7 @@ class StateDB(object): This is a generator. ''' - + c = self.get_cursor() c.execute('SELECT job_id, path, exit FROM jobs') while True: |