summaryrefslogtreecommitdiff
path: root/joblib.py
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-03-13 21:03:59 +0100
committerschneefux <schneefux+commit@schneefux.xyz>2017-03-13 21:03:59 +0100
commitc78f3678a70dffa87c2b1606e1d3d8ffbcd4ed44 (patch)
tree1f4c82482880a5b1dd5b75f79962b58f714e8b47 /joblib.py
parentceea54d460812545866505683a8a1a365aa79214 (diff)
downloadjoblib-c78f3678a70dffa87c2b1606e1d3d8ffbcd4ed44.tar.gz
joblib-c78f3678a70dffa87c2b1606e1d3d8ffbcd4ed44.zip
do not fail if index already exists
Diffstat (limited to 'joblib.py')
-rw-r--r--joblib.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/joblib.py b/joblib.py
index ab107f8..7ea908c 100644
--- a/joblib.py
+++ b/joblib.py
@@ -53,7 +53,10 @@ class JobQueue(object):
)
""")
await self._con.execute("""
- CREATE UNIQUE INDEX ON jobs(priority, id)
+ CREATE UNIQUE INDEX
+ IF NOT EXISTS
+ jobs_priority_id_idx
+ ON jobs(priority, id)
""")
async def listen(self, channel, callback):