From c78f3678a70dffa87c2b1606e1d3d8ffbcd4ed44 Mon Sep 17 00:00:00 2001 From: schneefux Date: Mon, 13 Mar 2017 21:03:59 +0100 Subject: do not fail if index already exists --- joblib.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'joblib.py') 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): -- cgit v1.3.1