Fix deleting existing backfill queue items

2023-01-03 20:45:55 +02:00
parent e3d2a1fcef
commit f1f0b86696
1 changed files with 1 additions and 1 deletions
@@ -186,7 +186,7 @@ class Backfill:
          AND type=$4
          AND dispatch_time IS NULL
          AND completed_at IS NULL
-        RETURNING {self.columns_str}
+        RETURNING queue_id, {self.columns_str}
        """
        q = f"""
        INSERT INTO backfill_queue ({self.columns_str})