Create an index on can_start_at too

flix-tech · Mar 26, 2024 · 9074f61 · 9074f61
1 parent d9a05d8
commit 9074f61
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/postgrestq/task_queue.py b/postgrestq/task_queue.py
@@ -98,6 +98,14 @@ def _create_queue_table(self) -> None:
                         )"""
                 ).format(sql.Identifier(self._table_name))
             )
+            cur.execute(
+                sql.SQL(
+                    """CREATE INDEX IF NOT EXISTS
+                        task_queue_can_start_at_idx
+                        ON {} (can_start_at)
+                    """
+                ).format(sql.Identifier(self._table_name))
+            )
 
     def __len__(self) -> int:
         """