From 639525935c8f3afcda3c78ea846e6f6bfaa8359f Mon Sep 17 00:00:00 2001
From: Matt Aitken <matt@mattaitken.com>
Date: Thu, 12 Sep 2024 11:24:06 +0100
Subject: [PATCH] Added more logs when resuming a dependency, added the runId

---
 .../app/v3/services/resumeTaskDependency.server.ts    | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/apps/webapp/app/v3/services/resumeTaskDependency.server.ts b/apps/webapp/app/v3/services/resumeTaskDependency.server.ts
index 1effffc0c..ac912f904 100644
--- a/apps/webapp/app/v3/services/resumeTaskDependency.server.ts
+++ b/apps/webapp/app/v3/services/resumeTaskDependency.server.ts
@@ -39,6 +39,16 @@ export class ResumeTaskDependencyService extends BaseService {
     const dependentRun = dependency.dependentAttempt.taskRun;
 
     if (dependency.dependentAttempt.status === "PAUSED" && dependency.checkpointEventId) {
+      logger.debug(
+        "Task dependency resume: Attempt is paused and there's a checkpoint. Enqueuing resume with checkpoint.",
+        {
+          attemptId: dependency.id,
+          dependentAttempt: dependency.dependentAttempt,
+          checkpointEventId: dependency.checkpointEventId,
+          hasCheckpointEvent: !!dependency.checkpointEventId,
+          runId: dependentRun.id,
+        }
+      );
       await marqs?.enqueueMessage(
         dependency.taskRun.runtimeEnvironment,
         dependentRun.queue,
@@ -61,6 +71,7 @@ export class ResumeTaskDependencyService extends BaseService {
         dependentAttempt: dependency.dependentAttempt,
         checkpointEventId: dependency.checkpointEventId,
         hasCheckpointEvent: !!dependency.checkpointEventId,
+        runId: dependentRun.id,
       });
 
       if (dependency.dependentAttempt.status === "PAUSED" && !dependency.checkpointEventId) {