Remove all TaskRun.tags readers and replace with TaskRun.runTags

Author: ericallam

apps/webapp/app/presenters/v3/ApiRetrieveRunPresenter.server.ts

@@ -34,7 +34,7 @@ const commonRunSelect = {
   metadata: true,
   metadataType: true,
   ttl: true,
-  tags: true,
+  runTags: true,
   costInCents: true,
   baseCostInCents: true,
   usageDurationMs: true,
@@ -459,9 +459,7 @@ async function createCommonRunStructure(run: CommonRelatedRun, apiVersion: API_V
     durationMs: run.usageDurationMs,
     isTest: run.isTest,
     depth: run.depth,
-    tags: run.tags
-      .map((t: { name: string }) => t.name)
-      .sort((a: string, b: string) => a.localeCompare(b)),
+    tags: [...(run.runTags ?? [])].sort((a: string, b: string) => a.localeCompare(b)),
     ...ApiRetrieveRunPresenter.apiBooleanHelpersFromTaskRunStatus(run.status, apiVersion),
     triggerFunction: resolveTriggerFunction(run),
     batchId: run.batch?.friendlyId,

apps/webapp/app/routes/resources.runs.$runParam.ts

@@ -23,11 +23,7 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
       taskIdentifier: true,
       friendlyId: true,
       isTest: true,
-      tags: {
-        select: {
-          name: true,
-        },
-      },
+      runTags: true,
       machinePreset: true,
       lockedToVersion: {
         select: {
@@ -178,7 +174,7 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
     run: {
       id: run.friendlyId,
       createdAt: run.createdAt,
-      tags: run.tags.map((tag) => tag.name),
+      tags: run.runTags ?? [],
       isTest: run.isTest,
       idempotencyKey: run.idempotencyKey ?? undefined,
       startedAt: run.startedAt ?? run.createdAt,
@@ -244,7 +240,7 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
       isCustomQueue: !run.queue.startsWith("task/"),
       concurrencyKey: run.concurrencyKey,
     },
-    tags: run.tags.map((tag) => tag.name),
+    tags: run.runTags ?? [],
     baseCostInCents: run.baseCostInCents,
     costInCents: run.costInCents,
     totalCostInCents: run.costInCents + run.baseCostInCents,

apps/webapp/app/v3/marqs/sharedQueueConsumer.server.ts

@@ -750,7 +750,6 @@ export class SharedQueueConsumer {
           take: 1,
           orderBy: { number: "desc" },
         },
-        tags: true,
         checkpoints: {
           take: 1,
           orderBy: {
@@ -1648,7 +1647,7 @@ export const AttemptForExecutionGetPayload = {
         costInCents: true,
         baseCostInCents: true,
         maxDurationInSeconds: true,
-        tags: true,
+        runTags: true,
         taskEventStore: true,
       },
     },
@@ -1725,7 +1724,7 @@ class SharedQueueTasks {
         context: taskRun.context,
         createdAt: taskRun.createdAt,
         startedAt: taskRun.startedAt ?? taskRun.createdAt,
-        tags: taskRun.tags.map((tag) => tag.name),
+        tags: taskRun.runTags ?? [],
         isTest: taskRun.isTest,
         idempotencyKey: taskRun.idempotencyKey ?? undefined,
         durationMs: taskRun.usageDurationMs,

apps/webapp/app/v3/services/createTaskRunAttempt.server.ts

@@ -52,7 +52,6 @@ export class CreateTaskRunAttemptService extends BaseService {
           runtimeEnvironmentId: environment.id,
         },
         include: {
-          tags: true,
           attempts: {
             take: 1,
             orderBy: {
@@ -209,7 +208,7 @@ export class CreateTaskRunAttemptService extends BaseService {
           payloadType: taskRun.payloadType,
           context: taskRun.context,
           createdAt: taskRun.createdAt,
-          tags: taskRun.tags.map((tag) => tag.name),
+          tags: taskRun.runTags ?? [],
           isTest: taskRun.isTest,
           idempotencyKey: taskRun.idempotencyKey ?? undefined,
           startedAt: taskRun.startedAt ?? taskRun.createdAt,