fix: make currentWorkerId nullable (SetNull), use injected db for legacy fallback

Author: ericallam

apps/webapp/app/services/taskIdentifierRegistry.server.ts

@@ -136,7 +136,7 @@ export async function getTaskIdentifiers(
     return sortEntries(entries);
   }
 
-  const legacyRows = await getAllTaskIdentifiers($replica, environmentId);
+  const legacyRows = await getAllTaskIdentifiers(db, environmentId);
   const entries: TaskIdentifierEntry[] = legacyRows.map((t) => ({
     slug: t.slug,
     triggerSource: t.triggerSource,

internal-packages/database/prisma/migrations/20260413000001_add_task_identifier_table/migration.sql

@@ -5,7 +5,7 @@ CREATE TABLE "TaskIdentifier" (
     "projectId" TEXT NOT NULL,
     "slug" TEXT NOT NULL,
     "currentTriggerSource" "TaskTriggerSource" NOT NULL DEFAULT 'STANDARD',
-    "currentWorkerId" TEXT NOT NULL,
+    "currentWorkerId" TEXT,
     "firstSeenAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
     "lastSeenAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
     "isInLatestDeployment" BOOLEAN NOT NULL DEFAULT true,
@@ -37,4 +37,4 @@ ALTER TABLE "TaskIdentifier"
 ALTER TABLE "TaskIdentifier"
     ADD CONSTRAINT "TaskIdentifier_currentWorkerId_fkey"
     FOREIGN KEY ("currentWorkerId") REFERENCES "BackgroundWorker"("id")
-    ON DELETE CASCADE ON UPDATE CASCADE;
+    ON DELETE SET NULL ON UPDATE CASCADE;

internal-packages/database/prisma/schema.prisma

@@ -2938,8 +2938,8 @@ model TaskIdentifier {
 
   currentTriggerSource TaskTriggerSource @default(STANDARD)
 
-  currentWorker   BackgroundWorker @relation(fields: [currentWorkerId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  currentWorkerId String
+  currentWorker   BackgroundWorker? @relation(fields: [currentWorkerId], references: [id], onDelete: SetNull, onUpdate: Cascade)
+  currentWorkerId String?
 
   firstSeenAt          DateTime @default(now())
   lastSeenAt           DateTime @default(now())