create an index on priority, id

1 files changed, 3 insertions, 0 deletions

diff --git a/joblib.py b/joblib.py
index 1b77b2e..8faf71f 100644
--- a/joblib.py
+++ b/joblib.py
@@ -40,6 +40,9 @@ class JobQueue(object):
                     payload JSONB
                 )
                 """)
+            await con.execute("""
+                CREATE UNIQUE INDEX ON jobs(priority, id)
+            """)
 
     async def request(self, jobtype, payload, priority=0):
         """Create a new job and return its id."""