diff --git a/include/upgrader/streams/core/934b8db8-ad9d0a5f.task.php b/include/upgrader/streams/core/934b8db8-ad9d0a5f.task.php
index 29a3a4b8c71c1a2cfbf191f03f8cb8fc2fb032c8..f83f7c8b352f04e987b964dfdd57003742a32d28 100644
--- a/include/upgrader/streams/core/934b8db8-ad9d0a5f.task.php
+++ b/include/upgrader/streams/core/934b8db8-ad9d0a5f.task.php
@@ -9,14 +9,24 @@ class QueueSortCreator extends MigrationTask {
         foreach ($columns as $C) {
             QueueColumn::__create($C);
         }
-        // Make room for the new queues starting at ID 1
-        $id = new SqlField('id');
-        CustomQueue::objects()->update(['id' => $id->plus(30)]);
+
+        // Save old records
+        $old = db_assoc_array(db_query('SELECT * FROM '.QUEUE_TABLE));
+        // Truncate Queue table - make room for the new queues starting at ID 1
+        db_query('TRUNCATE TABLE '.QUEUE_TABLE);
         $queues = $i18n->getTemplate('queue.yaml')->getData();
         foreach ($queues as $C) {
             CustomQueue::__create($C);
         }
 
+        // Re-insert old saved searches
+        foreach ($old ?: array() as $row) {
+            $row['root'] = 'T';
+            CustomQueue::__create(array_intersect_key($row, array_flip(
+                            array('staff_id', 'title', 'config', 'flags',
+                                'created', 'updated'))));
+        }
+
         $columns = $i18n->getTemplate('queue_sort.yaml')->getData();
         foreach ($columns as $C) {
             QueueSort::__create($C);