fix(run-ops split): don't drop queue ack/waitpoint completion when env resolution is unavailable

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: d-cs

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

@@ -121,7 +121,7 @@ export class DelayedRunSystem {
       const env = await this.$.controlPlaneResolver.resolveEnv(run.runtimeEnvironmentId);
 
       if (!env) {
-        throw new Error(`#enqueueDelayedRun: run not found: ${runId}`);
+        throw new Error(`#enqueueDelayedRun: environment not found for run: ${runId}`);
       }
 
       // Check if delayUntil has been rescheduled to the future (e.g., by debounce)

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

@@ -772,6 +772,7 @@ export class DequeueSystem {
 
       if (!env) {
         this.$.logger.error("RunEngine.#pendingVersion(): environment not found", { runId });
+        await this.$.runQueue.acknowledgeMessage(orgId, runId);
         return;
       }
 

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

@@ -101,16 +101,7 @@ export class TtlSystem {
         prisma
       );
 
-      const env = await this.$.controlPlaneResolver.resolveEnv(updatedRun.runtimeEnvironmentId);
-
-      if (!env) {
-        this.$.logger.debug("Run cannot be expired because its environment was not found", {
-          runId,
-        });
-        return;
-      }
-
-      await this.$.runQueue.acknowledgeMessage(env.organizationId, runId, {
+      await this.$.runQueue.acknowledgeMessage(snapshot.organizationId, runId, {
         removeFromWorkerQueue: true,
       });
 
@@ -125,9 +116,9 @@ export class TtlSystem {
       this.$.eventBus.emit("runExpired", {
         run: updatedRun,
         time: new Date(),
-        organization: { id: env.organizationId },
-        project: { id: env.projectId },
-        environment: { id: env.id },
+        organization: { id: snapshot.organizationId },
+        project: { id: snapshot.projectId },
+        environment: { id: snapshot.environmentId },
       });
     });
   }

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

@@ -739,7 +739,9 @@ export class WaitpointSystem {
           runId,
           runtimeEnvironmentId: run.runtimeEnvironmentId,
         });
-        throw new Error(`continueRunIfUnblocked: run not found: ${runId}`);
+        throw new Error(
+          `continueRunIfUnblocked: environment not found: ${run.runtimeEnvironmentId}`
+        );
       }
 
       //4. Continue the run whether it's executing or not