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):