pull out run execution logic

Author: nicktrn

internal-packages/run-engine/src/engine/db/worker.ts

@@ -193,7 +193,7 @@ export async function getWorkerDeploymentFromWorker(
   prisma: PrismaClientOrTransaction,
   workerId: string
 ): Promise<WorkerDeploymentWithWorkerTasks | null> {
-  const worker = await prisma.backgroundWorker.findUnique({
+  const worker = await prisma.backgroundWorker.findFirst({
     where: {
       id: workerId,
     },
@@ -264,6 +264,7 @@ export async function getWorkerFromCurrentlyPromotedDeployment(
   prisma: PrismaClientOrTransaction,
   environmentId: string
 ): Promise<WorkerDeploymentWithWorkerTasks | null> {
+  // TODO: fixme
   const promotion = await prisma.workerDeploymentPromotion.findUnique({
     where: {
       environmentId_label: {

packages/cli-v3/e2e/utils.ts

@@ -8,6 +8,7 @@ import { TaskRunProcess } from "../src/executions/taskRunProcess.js";
 import { createTestHttpServer } from "@epic-web/test-server/http";
 import { TestCase, TestCaseRun } from "./fixtures.js";
 import { access } from "node:fs/promises";
+import { MachinePreset } from "@trigger.dev/core/v3";
 
 export type PackageManager = "npm" | "pnpm" | "yarn";
 
@@ -295,6 +296,13 @@ export async function executeTestCaseRun({
     },
   });
 
+  const machine = {
+    name: "small-1x",
+    cpu: 1,
+    memory: 256,
+    centsPerMs: 0.0000001,
+  } satisfies MachinePreset;
+
   try {
     const taskRunProcess = new TaskRunProcess({
       workerManifest: workerManifest!,
@@ -314,12 +322,7 @@ export async function executeTestCaseRun({
         version: "1.0.0",
         contentHash,
       },
-      machine: {
-        name: "small-1x",
-        cpu: 1,
-        memory: 256,
-        centsPerMs: 0.0000001,
-      },
+      machineResources: machine,
     }).initialize();
 
     const result = await taskRunProcess.execute({
@@ -372,12 +375,7 @@ export async function executeTestCaseRun({
             ref: "main",
             name: "test",
           },
-          machine: {
-            name: "small-1x",
-            cpu: 1,
-            memory: 256,
-            centsPerMs: 0.0000001,
-          },
+          machine,
         },
       },
       messageId: "run_1234",

packages/cli-v3/src/entryPoints/dev-run-controller.ts

@@ -619,7 +619,7 @@ export class DevRunController {
         version: this.opts.worker.serverWorker?.version,
         engine: "V2",
       },
-      machine: execution.machine,
+      machineResources: execution.machine,
     }).initialize();
 
     logger.debug("executing task run process", {