Use createdAt for ordering realtime runs instead of number

Author: ericallam

packages/react-hooks/src/hooks/useRealtime.ts

@@ -591,7 +591,7 @@ async function processRealtimeBatch<TTask extends AnyTask = AnyTask>(
   }
 }
 
-// Inserts and then orders by the run number, and ensures that the run is not duplicated
+// Inserts and then orders by the run createdAt timestamp, and ensures that the run is not duplicated
 function insertRunShapeInOrder<TTask extends AnyTask>(
   previousRuns: RealtimeRun<TTask>[],
   run: RealtimeRun<TTask>
@@ -601,8 +601,8 @@ function insertRunShapeInOrder<TTask extends AnyTask>(
     return previousRuns.map((r) => (r.id === run.id ? run : r));
   }
 
-  const runNumber = run.number;
-  const index = previousRuns.findIndex((r) => r.number > runNumber);
+  const runCreatedAt = run.createdAt;
+  const index = previousRuns.findIndex((r) => r.createdAt > runCreatedAt);
   if (index === -1) {
     return [...previousRuns, run];
   }

references/hello-world/src/trigger/statuses.ts

@@ -0,0 +1,29 @@
+import { logger, runs, task } from "@trigger.dev/sdk";
+
+export const statusesTest = task({
+  id: "statuses-test",
+  run: async () => {
+    console.log("statusesTest");
+  },
+});
+
+export const subscribeToRun = task({
+  id: "subscribe-to-run",
+  run: async (payload: { runId: string }) => {
+    const subscription = runs.subscribeToRun(payload.runId, {
+      stopOnCompletion: false,
+    });
+
+    for await (const event of subscription) {
+      logger.info("run event", { event });
+    }
+  },
+});
+
+export const retrieveRun = task({
+  id: "retrieve-run",
+  run: async (payload: { runId: string }) => {
+    const run = await runs.retrieve(payload.runId);
+    logger.info("run", { run });
+  },
+});