lavatech/sublime-rana
2
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

disable queue until bug fixed

Browse source
This commit is contained in:
Alan Hamlett 2014-05-26 14:06:36 -07:00
parent e5e399dfbe
commit 17fd6ef8e1
1 changed files with 28 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

45
packages/wakatime/wakatime/queue.py
View file

@ -24,7 +24,6 @@ class Queue(object):
DB_FILE = os.path.join(os.path.expanduser('~'), '.wakatime.db') DB_FILE = os.path.join(os.path.expanduser('~'), '.wakatime.db')
def connect(self): def connect(self):
exists = os.path.exists(self.DB_FILE)
conn = sqlite3.connect(self.DB_FILE) conn = sqlite3.connect(self.DB_FILE)
c = conn.cursor() c = conn.cursor()
c.execute('''CREATE TABLE IF NOT EXISTS action ( c.execute('''CREATE TABLE IF NOT EXISTS action (
@ -41,27 +40,35 @@ class Queue(object):
def push(self, data, plugin): def push(self, data, plugin):
conn, c = self.connect() try:
action = { conn, c = self.connect()
'file': data.get('file'), action = {
'time': data.get('time'), 'file': data.get('file'),
'project': data.get('project'), 'time': data.get('time'),
'language': data.get('language'), 'project': data.get('project'),
'lines': data.get('lines'), 'language': data.get('language'),
'branch': data.get('branch'), 'lines': data.get('lines'),
'is_write': 1 if data.get('is_write') else 0, 'branch': data.get('branch'),
'plugin': plugin, 'is_write': 1 if data.get('is_write') else 0,
} 'plugin': plugin,
c.execute('INSERT INTO action VALUES (:file,:time,:project,:language,:lines,:branch,:is_write,:plugin)', action) }
conn.commit() c.execute('INSERT INTO action VALUES (:file,:time,:project,:language,:lines,:branch,:is_write,:plugin)', action)
conn.close() conn.commit()
conn.close()
except sqlite3.Error, e:
log.error(str(e))
def pop(self): def pop(self):
return None
tries = 3 tries = 3
wait = 0.1 wait = 0.1
action = None action = None
conn, c = self.connect() try:
conn, c = self.connect()
except sqlite3.Error, e:
log.debug(str(e))
return None
loop = True loop = True
while loop and tries > -1: while loop and tries > -1:
try: try:
@ -69,6 +76,7 @@ class Queue(object):
c.execute('SELECT * FROM action LIMIT 1') c.execute('SELECT * FROM action LIMIT 1')
row = c.fetchone() row = c.fetchone()
if row is not None: if row is not None:
log.info(row)
c.execute('''DELETE FROM action WHERE c.execute('''DELETE FROM action WHERE
file=? AND time=? AND project=? AND language=? AND file=? AND time=? AND project=? AND language=? AND
lines=? AND branch=? AND is_write=?''', row[0:7]) lines=? AND branch=? AND is_write=?''', row[0:7])
@ -89,5 +97,8 @@ class Queue(object):
log.debug(str(e)) log.debug(str(e))
sleep(wait) sleep(wait)
tries -= 1 tries -= 1
conn.close() try:
conn.close()
except sqlite3.Error, e:
log.debug(str(e))
return action return action