diff --git a/cluster4npu_ui/core/functions/InferencePipeline.py b/cluster4npu_ui/core/functions/InferencePipeline.py index f73618f..760f672 100644 --- a/cluster4npu_ui/core/functions/InferencePipeline.py +++ b/cluster4npu_ui/core/functions/InferencePipeline.py @@ -485,10 +485,7 @@ class InferencePipeline: # Call result callback if self.result_callback: - print(f"๐Ÿ” PIPELINE DEBUG: Calling result_callback with: {current_data}") self.result_callback(current_data) - else: - print(f"๐Ÿ” PIPELINE DEBUG: No result_callback set!") except queue.Full: # Drop oldest and add new diff --git a/cluster4npu_ui/core/functions/workflow_orchestrator.py b/cluster4npu_ui/core/functions/workflow_orchestrator.py index abc9da4..5235ba3 100644 --- a/cluster4npu_ui/core/functions/workflow_orchestrator.py +++ b/cluster4npu_ui/core/functions/workflow_orchestrator.py @@ -61,7 +61,6 @@ class WorkflowOrchestrator: # Set the result callback on the pipeline - always set this regardless of result_handler # The handle_result method will decide what to do with the results self.pipeline.set_result_callback(self.handle_result) - print(f"๐Ÿ” ORCHESTRATOR DEBUG: Set result callback on pipeline") # Start the pipeline self.pipeline.initialize() @@ -160,9 +159,6 @@ class WorkflowOrchestrator: """ Callback function to handle results from the pipeline. """ - print(f"๐Ÿ” ORCHESTRATOR DEBUG: handle_result called with: {result_data}") - print(f"๐Ÿ” ORCHESTRATOR DEBUG: result_callback is: {self.result_callback}") - try: # Convert PipelineData to a dictionary for serialization result_dict = { @@ -182,10 +178,7 @@ class WorkflowOrchestrator: # Always call the result callback if set (for GUI updates) if self.result_callback: - print(f"๐Ÿ” ORCHESTRATOR DEBUG: Calling result_callback with: {result_dict}") self.result_callback(result_dict) - else: - print(f"๐Ÿ” ORCHESTRATOR DEBUG: No result_callback set in orchestrator!") except Exception as e: print(f"โŒ Error handling result: {e}") diff --git a/cluster4npu_ui/ui/dialogs/deployment.py b/cluster4npu_ui/ui/dialogs/deployment.py index ad19db8..52f6253 100644 --- a/cluster4npu_ui/ui/dialogs/deployment.py +++ b/cluster4npu_ui/ui/dialogs/deployment.py @@ -23,7 +23,6 @@ import sys import json import threading import traceback -import time from typing import Dict, Any, List, Optional from PyQt5.QtWidgets import ( QDialog, QVBoxLayout, QHBoxLayout, QLabel, QTextEdit, QPushButton, @@ -137,10 +136,6 @@ class DeploymentWorker(QThread): # Set up both GUI and terminal result callbacks def combined_result_callback(result_dict): - # Debug print to see what we're receiving - print(f"๐Ÿ” DEBUG: Received result_dict in callback: {result_dict}") - print(f"๐Ÿ” DEBUG: Stage results: {result_dict.get('stage_results', {})}") - # Send to GUI terminal and results display terminal_output = self._format_terminal_results(result_dict) self.terminal_output.emit(terminal_output) @@ -149,18 +144,6 @@ class DeploymentWorker(QThread): self.orchestrator.set_result_callback(combined_result_callback) - # Test emit a sample result to verify GUI connection - test_result = { - 'pipeline_id': 'test_pipeline', - 'timestamp': time.time(), - 'stage_results': { - 'test_stage': (-0.5, 'Test Result') - }, - 'metadata': {} - } - print("๐Ÿ” DEBUG: Emitting test result to verify GUI connection") - self.result_updated.emit(test_result) - self.terminal_output.emit("๐Ÿงช TEST: This is a test terminal message") self.orchestrator.start() @@ -675,8 +658,6 @@ Stage Configurations: self.deployment_worker.result_updated.connect(self.update_inference_results) self.deployment_worker.terminal_output.connect(self.update_terminal_output) - # Test the signal connections - print("๐Ÿ” DEBUG: Signal connections established") self.deployment_worker.start() @@ -792,9 +773,6 @@ Stage Configurations: import json from datetime import datetime - # Debug: Print what we received - print(f"๐Ÿ” GUI DEBUG: update_inference_results called with: {result_dict}") - # Format the results for display timestamp = datetime.fromtimestamp(result_dict.get('timestamp', 0)).strftime("%H:%M:%S.%f")[:-3] stage_results = result_dict.get('stage_results', {})