Better logs for payload retrieval issues

Author: nicktrn

apps/webapp/app/v3/handleSocketIo.server.ts

@@ -104,13 +104,16 @@ function createCoordinatorNamespace(io: Server) {
           );
 
           if (!payload) {
-            logger.error("Failed to retrieve lazy attempt payload", message);
-            return { success: false, reason: "Failed to retrieve payload" };
+            logger.error(
+              "READY_FOR_LAZY_ATTEMPT: Failed to retrieve lazy attempt payload",
+              message
+            );
+            return { success: false, reason: "READY_FOR_LAZY_ATTEMPT: Failed to retrieve payload" };
           }
 
           return { success: true, lazyPayload: payload };
         } catch (error) {
-          logger.error("Error while creating lazy attempt", {
+          logger.error("READY_FOR_LAZY_ATTEMPT: Error while creating lazy attempt", {
             runId: message.runId,
             envId: message.envId,
             totalCompletions: message.totalCompletions,
@@ -207,13 +210,19 @@ function createCoordinatorNamespace(io: Server) {
           });
 
           if (!payload) {
-            logger.error("Failed to retrieve payload after attempt creation", message);
-            return { success: false, reason: "Failed to retrieve payload" };
+            logger.error(
+              "CREATE_TASK_RUN_ATTEMPT: Failed to retrieve payload after attempt creation",
+              message
+            );
+            return {
+              success: false,
+              reason: "CREATE_TASK_RUN_ATTEMPT: Failed to retrieve payload",
+            };
           }
 
           return { success: true, executionPayload: payload };
         } catch (error) {
-          logger.error("Error while creating attempt", {
+          logger.error("CREATE_TASK_RUN_ATTEMPT: Error while creating attempt", {
             ...message,
             error,
           });

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

@@ -1086,18 +1086,21 @@ class SharedQueueTasks {
     });
 
     if (!attempt) {
-      logger.error("No attempt found", { id });
+      logger.error("getExecutionPayloadFromAttempt: No attempt found", { id });
       return;
     }
 
     if (!skipStatusChecks) {
       switch (attempt.status) {
         case "CANCELED":
         case "EXECUTING": {
-          logger.error("Invalid attempt status for execution payload retrieval", {
-            attemptId: id,
-            status: attempt.status,
-          });
+          logger.error(
+            "getExecutionPayloadFromAttempt: Invalid attempt status for execution payload retrieval",
+            {
+              attemptId: id,
+              status: attempt.status,
+            }
+          );
           return;
         }
       }
@@ -1106,19 +1109,22 @@ class SharedQueueTasks {
         case "CANCELED":
         case "EXECUTING":
         case "INTERRUPTED": {
-          logger.error("Invalid run status for execution payload retrieval", {
-            attemptId: id,
-            runId: attempt.taskRunId,
-            status: attempt.taskRun.status,
-          });
+          logger.error(
+            "getExecutionPayloadFromAttempt: Invalid run status for execution payload retrieval",
+            {
+              attemptId: id,
+              runId: attempt.taskRunId,
+              status: attempt.taskRun.status,
+            }
+          );
           return;
         }
       }
     }
 
     if (setToExecuting) {
       if (isFinalAttemptStatus(attempt.status) || isFinalRunStatus(attempt.taskRun.status)) {
-        logger.error("Status already in final state", {
+        logger.error("getExecutionPayloadFromAttempt: Status already in final state", {
           attempt: {
             id: attempt.id,
             status: attempt.status,
@@ -1309,7 +1315,7 @@ class SharedQueueTasks {
       },
     });
 
-    logger.debug("Getting lazy attempt payload for run", {
+    logger.debug("getLazyAttemptPayload: Getting lazy attempt payload for run", {
       run,
       attemptCount,
     });