fix: retry failed release RTT rows (#17)

Author: vincentkoc

scripts/resolve-openclaw-channel-package.mjs

@@ -114,16 +114,19 @@ const explicitVersions = readListEnv("INPUT_VERSIONS");
 const versionLimit = readPositiveIntegerEnv("INPUT_VERSION_LIMIT", DEFAULT_VERSION_LIMIT);
 const channelRows = releaseRows(await readChannelRttRows());
 const measured = new Set(
-  channelRows.map(
-    (row) => `${row.channel?.id}\0${row.package?.spec}\0${row.package?.version}`,
-  ),
+  channelRows
+    .filter((row) => row.run?.status === "pass")
+    .map(
+      (row) => `${row.channel?.id}\0${row.package?.spec}\0${row.package?.version}`,
+    ),
 );
 
 const queue = [];
 for (const channelId of channelIds) {
   const channel = channelConfig.get(channelId);
   const measuredVersions = channelRows
     .filter((row) => row.channel?.id === channelId)
+    .filter((row) => row.run?.status === "pass")
     .map((row) => row.package.version)
     .filter((version) => parseVersion(version));
   const latestMeasured = measuredVersions.sort(compareVersions).at(-1);

scripts/resolve-openclaw-channel-package.test.mjs

@@ -94,7 +94,7 @@ test("queues explicit channel release versions even when already measured", asyn
   ]);
 });
 
-test("does not auto-requeue imported channel release versions", async () => {
+test("auto-requeues failed channel release versions", async () => {
   const workspace = await makeWorkspace();
   await writeJsonl(path.join(workspace, "data/channels/slack/2026.5.16-beta.6.jsonl"), [
     row("2026.5.16-beta.6", "slack", "fail"),
@@ -119,6 +119,7 @@ test("does not auto-requeue imported channel release versions", async () => {
   );
   const matrix = JSON.parse(outputs.matrix);
   assert.deepEqual(matrix.map((entry) => `${entry.channel}:${entry.version}`), [
+    "slack:2026.5.16-beta.6",
     "whatsapp:2026.5.16-beta.6",
     "slack:2026.5.16-beta.7",
     "whatsapp:2026.5.16-beta.7",

scripts/resolve-openclaw-discord-package.mjs

@@ -178,7 +178,7 @@ if (requestedVersions.length > 0) {
     .slice(0, rssBackfillLimit);
 } else {
   const measured = new Set(
-    discordRows.map((row) => `${row.package.spec}\0${row.package.version}`),
+    successfulDiscordRows.map((row) => `${row.package.spec}\0${row.package.version}`),
   );
   queue = (await npmVersions())
     .filter((version) => typeof version === "string" && parseVersion(version))

scripts/resolve-openclaw-discord-package.test.mjs

@@ -115,7 +115,7 @@ test("queues missing Discord releases from the Telegram baseline", async () => {
   assert.deepEqual(JSON.parse(outputs.matrix).map((pkg) => pkg.version), ["2026.5.12"]);
 });
 
-test("does not requeue imported failed Discord releases by default", async () => {
+test("auto-requeues failed Discord releases by default", async () => {
   const workspace = await makeWorkspace();
   await writeJsonl(path.join(workspace, "data/channels/telegram.jsonl"), [
     releaseRow("2026.5.12", "telegram"),
@@ -142,10 +142,13 @@ test("does not requeue imported failed Discord releases by default", async () =>
   });
 
   const outputs = parseOutputs(stdout);
-  assert.equal(outputs.count, "1");
-  assert.equal(outputs.missing_baseline_count, "1");
+  assert.equal(outputs.count, "2");
+  assert.equal(outputs.missing_baseline_count, "2");
   assert.equal(outputs.reason, "missing-discord-release-versions");
-  assert.deepEqual(JSON.parse(outputs.matrix).map((pkg) => pkg.version), ["2026.5.16-beta.6"]);
+  assert.deepEqual(JSON.parse(outputs.matrix).map((pkg) => pkg.version), [
+    "2026.5.16-beta.5",
+    "2026.5.16-beta.6",
+  ]);
 });
 
 test("queues requested Discord releases even when a failed row was imported", async () => {

scripts/resolve-openclaw-surface-package.mjs

@@ -121,7 +121,9 @@ for (const surfaceId of surfaceIds) {
 }
 const measured = new Set(
   [...rowsBySurface.entries()].flatMap(([surfaceId, rows]) =>
-    rows.map((row) => `${surfaceId}\0${row.package?.spec}\0${row.package?.version}`),
+    rows
+      .filter((row) => row.run?.status === "pass")
+      .map((row) => `${surfaceId}\0${row.package?.spec}\0${row.package?.version}`),
   ),
 );
 
@@ -130,6 +132,7 @@ for (const surfaceId of surfaceIds) {
   const surface = surfaceConfig.get(surfaceId);
   const surfaceRows = rowsBySurface.get(surfaceId) ?? [];
   const measuredVersions = surfaceRows
+    .filter((row) => row.run?.status === "pass")
     .map((row) => row.package.version)
     .filter((version) => parseVersion(version));
   const latestMeasured = measuredVersions.sort(compareVersions).at(-1);

scripts/resolve-openclaw-surface-package.test.mjs

@@ -93,7 +93,7 @@ test("queues explicit surface release versions even when already measured", asyn
   ]);
 });
 
-test("does not auto-requeue imported surface release versions", async () => {
+test("auto-requeues failed surface release versions", async () => {
   const workspace = await makeWorkspace();
   await writeJsonl(path.join(workspace, "data/surfaces/control-ui/2026.6.1-beta.3.jsonl"), [
     row("2026.6.1-beta.3", "control-ui", "fail"),
@@ -113,6 +113,7 @@ test("does not auto-requeue imported surface release versions", async () => {
   const outputs = parseOutputs(stdout);
   const matrix = JSON.parse(outputs.matrix);
   assert.deepEqual(matrix.map((entry) => `${entry.surface}:${entry.version}`), [
+    "control-ui:2026.6.1-beta.3",
     "control-ui:2026.6.1",
   ]);
 });