Fix BullMQ job dedup — remove completed/failed jobs

Completed jobs with the same jobId block new jobs from being added.
Add removeOnComplete and removeOnFail to all job options so the same
task can be re-triggered after completion.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

coder/cloudflare-worker/main.tf

@@ -128,6 +128,10 @@ data "coder_parameter" "task_type" {
     name  = "Rework PR"
     value = "rework-pr"
   }
+  option {
+    name  = "Rework Spec"
+    value = "rework-spec"
+  }
   option {
     name  = "Release"
     value = "release"
@@ -470,7 +474,7 @@ resource "coder_agent" "main" {
       git fetch origin develop 2>/dev/null && git checkout develop 2>/dev/null || true
 
       # Lightweight stages only need the code, not a full build
-      LIGHT_STAGES="analyse architect release maintenance"
+      LIGHT_STAGES="analyse architect rework-spec release maintenance"
       if echo "$LIGHT_STAGES" | grep -qw "$TASK_TYPE"; then
         echo "Lightweight stage ($TASK_TYPE) — skipping build"
       else

src/handlers/pr-rework.ts

@@ -16,7 +16,8 @@ export function prRework(config: Config, queue: TaskQueue) {
       return c.text("ignored: not a reviewed event", 200);
     }
 
-    if (!event.review) {
+    if (!event.review?.state) {
+      console.log(`[pr-rework] ignored: no review state (review: ${JSON.stringify(event.review)})`);
       return c.text("ignored: no review data", 200);
     }
 
@@ -26,9 +27,11 @@ export function prRework(config: Config, queue: TaskQueue) {
 
     let taskType: string | null = null;
     let giteaToken: string;
+    const branch = event.pull_request.head.ref;
+    const isArchitectPR = branch.startsWith("docs/");
 
     if (reviewState === "request_changes") {
-      taskType = "rework-pr";
+      taskType = isArchitectPR ? "rework-spec" : "rework-pr";
       giteaToken = config.giteaDevToken;
     } else if (reviewState === "approved") {
       taskType = "test";

src/queue.ts

@@ -161,6 +161,8 @@ export class TaskQueue {
           jobId: `create-${key}`,
           attempts: 3,
           backoff: { type: "exponential", delay: 5000 },
+          removeOnComplete: true,
+          removeOnFail: true,
         },
       );
     } catch (err: unknown) {
@@ -201,6 +203,8 @@ export class TaskQueue {
         jobId: `cleanup-${workspaceName}`,
         attempts: 5,
         backoff: { type: "exponential", delay: 10000 },
+        removeOnComplete: true,
+        removeOnFail: true,
       },
     );
 
@@ -311,6 +315,8 @@ export class TaskQueue {
                 jobId: `cleanup-stale-${ws.name}-${Date.now()}`,
                 attempts: 5,
                 backoff: { type: "exponential", delay: 10000 },
+                removeOnComplete: true,
+                removeOnFail: true,
               },
             );
           } catch (err) {