remove sqlite_helpers

This commit is contained in:
Jack Robison 2018-02-12 13:44:32 -05:00
parent e671005c3c
commit af87df3709
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2

View file

@ -1,23 +0,0 @@
import sqlite3
from twisted.internet import task, reactor
import logging
log = logging.getLogger(__name__)
def rerun_if_locked(f):
def rerun(err, *args, **kwargs):
if err.check(sqlite3.OperationalError) and err.value.message == "database is locked":
log.warning("database was locked. rerunning %s with args %s, kwargs %s",
str(f), str(args), str(kwargs))
return task.deferLater(reactor, 0, wrapper, *args, **kwargs)
return err
def wrapper(*args, **kwargs):
d = f(*args, **kwargs)
d.addErrback(rerun, *args, **kwargs)
return d
return wrapper