Revert "Temporary debugging"

This reverts commit c116441.

Author: ajlai-orkes

src/integration-tests/utils/waitForWorkflowStatus.ts

@@ -4,8 +4,6 @@ import { WorkflowExecutor } from "../../sdk";
 /**
  * Wait for workflow to reach expected status
  */
-const LOG_INTERVAL_MS = 15000;
-
 export const waitForWorkflowStatus = async (
   workflowClient: WorkflowExecutor,
   workflowId: string,
@@ -14,21 +12,13 @@ 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;
       }
 
@@ -38,15 +28,6 @@ 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) {
@@ -60,8 +41,7 @@ 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${lastStatusMsg}`
+    `Workflow did not reach status ${expectedStatus} within ${maxWaitTimeMs}ms`
   );
 };

src/sdk/clients/worker/TaskRunner.ts

@@ -197,11 +197,6 @@ 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,
@@ -212,12 +207,6 @@ 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 ?? "",
@@ -315,12 +304,6 @@ 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,