Merge branch 'main' into feat/python-extension-improvements

Author: ericallam

.changeset/cold-coins-burn.md

@@ -0,0 +1,7 @@
+---
+"@trigger.dev/react-hooks": patch
+"@trigger.dev/sdk": patch
+"trigger.dev": patch
+---
+
+Add support for two-phase deployments and task version pinning

.changeset/rude-news-dress.md

@@ -0,0 +1,5 @@
+---
+"trigger.dev": patch
+---
+
+Upgrade @clack/prompts to 0.10.0 to fix CI output

.changeset/silent-squids-glow.md

@@ -0,0 +1,5 @@
+---
+"trigger.dev": patch
+---
+
+Fixes needsPromotion github action output

apps/coordinator/src/index.ts

@@ -663,9 +663,25 @@ class TaskCoordinator {
 
             await chaosMonkey.call();
 
+            const lazyPayload = {
+              ...lazyAttempt.lazyPayload,
+              metrics: [
+                ...(message.startTime
+                  ? [
+                      {
+                        name: "start",
+                        event: "lazy_payload",
+                        timestamp: message.startTime,
+                        duration: Date.now() - message.startTime,
+                      },
+                    ]
+                  : []),
+              ],
+            };
+
             socket.emit("EXECUTE_TASK_RUN_LAZY_ATTEMPT", {
               version: "v1",
-              lazyPayload: lazyAttempt.lazyPayload,
+              lazyPayload,
             });
           } catch (error) {
             if (error instanceof ChaosMonkey.Error) {

apps/docker-provider/src/index.ts

@@ -122,14 +122,18 @@ class DockerTaskOperations implements TaskOperations {
       `--env=POD_NAME=${containerName}`,
       `--env=COORDINATOR_HOST=${COORDINATOR_HOST}`,
       `--env=COORDINATOR_PORT=${COORDINATOR_PORT}`,
-      `--env=SCHEDULED_AT_MS=${Date.now()}`,
+      `--env=TRIGGER_POD_SCHEDULED_AT_MS=${Date.now()}`,
       `--name=${containerName}`,
     ];
 
     if (process.env.ENFORCE_MACHINE_PRESETS) {
       runArgs.push(`--cpus=${opts.machine.cpu}`, `--memory=${opts.machine.memory}G`);
     }
 
+    if (opts.dequeuedAt) {
+      runArgs.push(`--env=TRIGGER_RUN_DEQUEUED_AT_MS=${opts.dequeuedAt}`);
+    }
+
     runArgs.push(`${opts.image}`);
 
     try {

apps/kubernetes-provider/src/index.ts

@@ -202,6 +202,9 @@ class KubernetesTaskOperations implements TaskOperations {
                   name: "TRIGGER_RUN_ID",
                   value: opts.runId,
                 },
+                ...(opts.dequeuedAt
+                  ? [{ name: "TRIGGER_RUN_DEQUEUED_AT_MS", value: String(opts.dequeuedAt) }]
+                  : []),
               ],
               volumeMounts: [
                 {
@@ -518,7 +521,7 @@ class KubernetesTaskOperations implements TaskOperations {
         },
       },
       {
-        name: "SCHEDULED_AT_MS",
+        name: "TRIGGER_POD_SCHEDULED_AT_MS",
         value: Date.now().toString(),
       },
       ...this.#coordinatorEnvVars,