fix dev dependecy resumes

Author: nicktrn

apps/webapp/app/v3/services/batchTriggerTask.server.ts

@@ -54,6 +54,28 @@ export class BatchTriggerTaskService extends BaseService {
           })
         : undefined;
 
+      if (dependentAttempt && environment.type === "DEVELOPMENT") {
+        // The dev worker handles dependency resumes and attempt completions in parallel, so we need to clear any existing ones here to prevent race conditions
+        const existingBatch = await this._prisma.batchTaskRun.findUnique({
+          where: {
+            dependentTaskAttemptId: dependentAttempt.id,
+          },
+        });
+
+        if (existingBatch) {
+          await this._prisma.batchTaskRun.update({
+            where: {
+              id: existingBatch.id,
+            },
+            data: {
+              dependentTaskAttempt: {
+                disconnect: true,
+              },
+            },
+          });
+        }
+      }
+
       const batch = await this._prisma.batchTaskRun.create({
         data: {
           friendlyId: generateFriendlyId("batch"),

apps/webapp/app/v3/services/triggerTask.server.ts

@@ -147,6 +147,28 @@ export class TriggerTaskService extends BaseService {
               });
 
               if (dependentAttempt) {
+                if (environment.type === "DEVELOPMENT") {
+                  // The dev worker handles dependency resumes and attempt completions in parallel, so we need to clear any existing ones here to prevent race conditions
+                  const existingDependency = await tx.taskRunDependency.findUnique({
+                    where: {
+                      dependentAttemptId: dependentAttempt.id,
+                    },
+                  });
+
+                  if (existingDependency) {
+                    await tx.taskRunDependency.update({
+                      where: {
+                        id: existingDependency.id,
+                      },
+                      data: {
+                        dependentAttempt: {
+                          disconnect: true,
+                        },
+                      },
+                    });
+                  }
+                }
+
                 await tx.taskRunDependency.create({
                   data: {
                     taskRunId: taskRun.id,