Cover queue_name in the index too

flix-tech · Apr 8, 2024 · 94e6d1a · 94e6d1a
1 parent 4737672
commit 94e6d1a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/postgrestq/task_queue.py b/postgrestq/task_queue.py
@@ -101,8 +101,8 @@ def _create_queue_table(self) -> None:
             cur.execute(
                 sql.SQL(
                     """CREATE INDEX IF NOT EXISTS
-                        task_queue_can_start_at_idx
-                        ON {} (can_start_at)
+                        task_queue_queue_name_can_start_at_idx
+                        ON {} (queue_name, can_start_at)
                     """
                 ).format(sql.Identifier(self._table_name))
             )