findUnique -> findFirst

Author: nicktrn

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

@@ -1000,7 +1000,7 @@ export class SharedQueueConsumer {
 
 class SharedQueueTasks {
   async getCompletionPayloadFromAttempt(id: string): Promise<TaskRunExecutionResult | undefined> {
-    const attempt = await prisma.taskRunAttempt.findUnique({
+    const attempt = await prisma.taskRunAttempt.findFirst({
       where: {
         id,
         status: {
@@ -1063,7 +1063,7 @@ class SharedQueueTasks {
     isRetrying?: boolean;
     skipStatusChecks?: boolean;
   }): Promise<ProdTaskRunExecutionPayload | undefined> {
-    const attempt = await prisma.taskRunAttempt.findUnique({
+    const attempt = await prisma.taskRunAttempt.findFirst({
       where: {
         id,
       },

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

@@ -22,7 +22,7 @@ export class ResumeAttemptService extends BaseService {
     this._logger.debug(`ResumeAttemptService.call()`, params);
 
     await $transaction(this._prisma, async (tx) => {
-      const attempt = await tx.taskRunAttempt.findUnique({
+      const attempt = await tx.taskRunAttempt.findFirst({
         where: {
           friendlyId: params.attemptFriendlyId,
         },
@@ -169,7 +169,7 @@ export class ResumeAttemptService extends BaseService {
     const executions: TaskRunExecution[] = [];
 
     for (const completedAttemptId of completedAttemptIds) {
-      const completedAttempt = await tx.taskRunAttempt.findUnique({
+      const completedAttempt = await tx.taskRunAttempt.findFirst({
         where: {
           id: completedAttemptId,
           taskRun: {