Temporary debugging

Author: ajlai-orkes

src/integration-tests/utils/waitForWorkflowStatus.ts

@@ -4,6 +4,8 @@ import { WorkflowExecutor } from "../../sdk";
 /**
  * Wait for workflow to reach expected status
  */
+const LOG_INTERVAL_MS = 15000;
+
 export const waitForWorkflowStatus = async (
   workflowClient: WorkflowExecutor,
   workflowId: string,
@@ -12,13 +14,21 @@ export const waitForWorkflowStatus = async (
   pollIntervalMs = 3000
 ): Promise<Workflow> => {
   const startTime = Date.now();
+  let lastLogTime = 0;
+  let lastStatus: string | undefined;
 
   let lastError: unknown;
   while (Date.now() - startTime < maxWaitTimeMs) {
     try {
       const workflow = await workflowClient.getWorkflow(workflowId, true);
+      const elapsed = Date.now() - startTime;
 
       if (workflow?.status === expectedStatus) {
+        if (process.env.CI && elapsed > 0) {
+          console.log(
+            `[waitForWorkflowStatus] workflowId=${workflowId} reached ${expectedStatus} in ${elapsed}ms`
+          );
+        }
         return workflow;
       }
 
@@ -28,6 +38,15 @@ export const waitForWorkflowStatus = async (
         );
       }
 
+      lastStatus = workflow?.status;
+
+      if (process.env.CI && Date.now() - lastLogTime >= LOG_INTERVAL_MS) {
+        lastLogTime = Date.now();
+        console.log(
+          `[waitForWorkflowStatus] workflowId=${workflowId} status=${workflow?.status ?? "undefined"} elapsed=${elapsed}ms (waiting for ${expectedStatus})`
+        );
+      }
+
       lastError = undefined;
       await new Promise((resolve) => setTimeout(resolve, pollIntervalMs));
     } catch (error) {
@@ -41,7 +60,8 @@ export const waitForWorkflowStatus = async (
     throw new Error(`Failed to get workflow status: ${lastError}`);
   }
 
+  const lastStatusMsg = lastStatus !== undefined ? `; last status was ${lastStatus}` : "";
   throw new Error(
-    `Workflow did not reach status ${expectedStatus} within ${maxWaitTimeMs}ms`
+    `Workflow did not reach status ${expectedStatus} within ${maxWaitTimeMs}ms${lastStatusMsg}`
   );
 };

src/sdk/clients/worker/TaskRunner.ts

@@ -197,6 +197,11 @@ export class TaskRunner {
 
     while (retryCount < this.maxRetries) {
       try {
+        if (process.env.CI) {
+          console.log(
+            `[TaskRunner] Submitting task result taskId=${taskResult.taskId} workflowId=${taskResult.workflowInstanceId} taskType=${this.worker.taskDefName} attempt=${retryCount + 1}/${this.maxRetries}`
+          );
+        }
         const updateStart = Date.now();
         const { data: nextTask } = await TaskResource.updateTaskV2({
           client: this._client,
@@ -207,6 +212,12 @@ export class TaskRunner {
         });
         const updateDurationMs = Date.now() - updateStart;
 
+        if (process.env.CI) {
+          console.log(
+            `[TaskRunner] Task result accepted taskId=${taskResult.taskId} durationMs=${updateDurationMs}`
+          );
+        }
+
         await this.eventDispatcher.publishTaskUpdateCompleted({
           taskType: this.worker.taskDefName,
           taskId: taskResult.taskId ?? "",
@@ -304,6 +315,12 @@ export class TaskRunner {
     const workflowInstanceId = task.workflowInstanceId as string;
     const startTime = Date.now();
 
+    if (process.env.CI) {
+      console.log(
+        `[TaskRunner] Executing task taskId=${taskId} workflowId=${workflowInstanceId} taskType=${this.worker.taskDefName}`
+      );
+    }
+
     // Publish TaskExecutionStarted event
     await this.eventDispatcher.publishTaskExecutionStarted({
       taskType: this.worker.taskDefName,