fix(run-engine): widen unblock transaction limits for batch-scale waitpoints

Pass explicit timeout/maxRetries to $transaction in continueRunIfUnblocked so
that large batchTriggerAndWait parents (hundreds of blocking waitpoint rows)
don't hit the 5s Prisma default and land in DLQ. Also removes a duplicate
post-send debug log, collapses a no-op re-spread in createExecutionSnapshot,
and documents that attemptSucceeded callers must pass a plain client.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

Author: d-cs

internal-packages/run-engine/src/engine/systems/executionSnapshotSystem.ts

@@ -491,11 +491,7 @@ export class ExecutionSnapshotSystem {
       completedWaitpoints: args.completedWaitpoints,
     });
 
-    return {
-      ...newSnapshot,
-      friendlyId: newSnapshot.friendlyId,
-      runFriendlyId: newSnapshot.runFriendlyId,
-    };
+    return newSnapshot;
   }
 
   public async heartbeatRun({

internal-packages/run-engine/src/engine/systems/runAttemptSystem.ts

@@ -688,6 +688,9 @@ export class RunAttemptSystem {
     runId: string;
     snapshotId: string;
     completion: TaskRunSuccessfulExecutionResult;
+    // Note: passing an open transaction as `tx` makes $transaction run inline in it,
+    // which would move this method's post-commit side effects inside the caller's
+    // transaction. Callers must pass a plain client.
     tx: PrismaClientOrTransaction;
     workerId?: string;
     runnerId?: string;

internal-packages/run-engine/src/engine/systems/waitpointSystem.ts

@@ -884,6 +884,12 @@ export class WaitpointSystem {
                 message: error.message,
                 runId,
               });
+            },
+            {
+              // the m2m connect inserts one row per blocking waitpoint, so large
+              // batchTriggerAndWait parents need more than the 5s default
+              timeout: 30_000,
+              maxRetries: 2,
             }
           );
 
@@ -914,11 +920,6 @@ export class WaitpointSystem {
             eventBus: this.$.eventBus,
           });
 
-          this.$.logger.debug(`continueRunIfUnblocked: removed blocking waitpoints`, {
-            runId,
-            blockingWaitpoints,
-          });
-
           return {
             status: "unblocked",
             waitpoints: blockingWaitpoints.map((w) => w.waitpoint),