fix: idle restart no migratios

[johnyeocx]

Summary by cubic

Prevent idle self-kill restarts while migration jobs are running to avoid interrupting migrations. We now track active migration jobs and only recycle the worker when idle and no migrations are active.

^{Written for commit beaa71d. Summary will update on new commits.}

Greptile Summary

This PR fixes a race condition where the SQS worker's idle self-kill logic could terminate the process while long-running migration jobs were still executing in the background.

Key Changes:

• Bug fixes — Introduces an activeMigrationJobs counter that is incremented before dispatching a migration job as fire-and-forget, and decremented in .finally() after it settles. The logStatsAndCheckZeroMessages idle self-kill condition now additionally requires activeMigrationJobs === 0 before calling process.exit(0), preventing premature worker termination during in-flight migrations.

Confidence Score: 5/5

• The fix is minimal, correct, and directly addresses the described race condition with no side effects.
• The counter increment/decrement pattern is sound in a single-threaded JS/Bun runtime. The .finally() block guarantees the decrement runs regardless of success or failure. The added condition at the idle self-kill check precisely targets the problematic code path where migrations could be killed mid-flight. The implementation is straightforward with no edge cases in the core fix.
• No files require special attention

Sequence Diagram

sequenceDiagram
    participant SQS
    participant PollLoop as Polling Loop
    participant Counter as activeMigrationJobs
    participant Handler as handleSingleMessage
    participant Stats as logStatsAndCheckZeroMessages

    SQS->>PollLoop: Message received (JobName.Migration)
    PollLoop->>Counter: activeMigrationJobs++ (now > 0)
    PollLoop->>Handler: fire-and-forget (no await)
    PollLoop->>SQS: continue polling

    Note over Stats: setInterval (every 60s)
    Stats->>Stats: messagesProcessed === 0?
    Stats->>Counter: activeMigrationJobs === 0?
    alt activeMigrationJobs > 0
        Stats-->>Stats: Skip idle self-kill (migration running)
    else activeMigrationJobs === 0
        Stats-->>Stats: process.exit(0) if idle threshold met
    end

    Handler-->>Handler: processMessage completes
    Handler->>Counter: activeMigrationJobs-- via .finally()

Loading

_{Last reviewed commit: beaa71d}

[vercel]

The latest updates on your projects. Learn more about Vercel for GitHub.

Project	Deployment	Actions	Updated (UTC)
autumn-vite	Ready	Preview, Comment	Mar 3, 2026 5:57pm

[cubic-dev-ai]

No issues found across 1 file

Confidence score: 5/5

• Automated review surfaced no issues in the provided summaries.
• No files require special attention.