Update app.py

app.py

@@ -12,7 +12,7 @@ import requests
 import threading
 
 # Configuration
-ORCHESTRATOR_VERSION = "1.0.0"
+ORCHESTRATOR_VERSION = "2.0.0"
 WORKER_HEALTH_CHECK_INTERVAL = 30  # seconds
 WORKER_TIMEOUT = 120  # seconds for translation
 
@@ -61,7 +61,6 @@ class TranslationOrchestrator:
         
     def load_worker_configs(self):
         """Load worker configurations from environment variables"""
-        # Format: WORKER_1_URL=https://..., WORKER_1_NAME=Worker1, etc.
         worker_index = 1
         while True:
             url_key = f"WORKER_{worker_index}_URL"
@@ -91,17 +90,16 @@ class TranslationOrchestrator:
         if not self.workers:
             print("⚠ No workers configured. Add WORKER_N_URL environment variables.")
 
-
     def start_health_checker(self):
-            """Start background thread for health checking"""
-            def health_check_loop():
-                while True:
-                    self.check_all_workers_health()
-                    time.sleep(WORKER_HEALTH_CHECK_INTERVAL)
-            
-            thread = threading.Thread(target=health_check_loop, daemon=True)
-            thread.start()
-            print("✓ Health checker started")
+        """Start background thread for health checking"""
+        def health_check_loop():
+            while True:
+                self.check_all_workers_health()
+                time.sleep(WORKER_HEALTH_CHECK_INTERVAL)
+        
+        thread = threading.Thread(target=health_check_loop, daemon=True)
+        thread.start()
+        print("✓ Health checker started")
     
     def check_all_workers_health(self):
         """Check health of all workers"""
@@ -276,52 +274,49 @@ class TranslationOrchestrator:
         # Timeout reached
         self.handle_worker_failure(worker_id, request_id, "Timeout waiting for completion")                
 
-
-
-
     def handle_job_completion(self, worker_id: str, request_id: str, worker_response: Dict):
-            """Handle successful job completion"""
-            worker = self.workers[worker_id]
-            
-            print(f"✅ Job {request_id} completed by {worker.config.name}")
-            
-            # Update worker stats
-            with self.worker_lock:
-                worker.active_jobs -= 1
-                worker.total_completed += 1
-            
-            # Get job data
-            job_info = self.active_jobs.get(request_id, {})
-            job_data = job_info.get('job_data', {})
-            
-            # Calculate processing time
-            processing_time = time.time() - job_info.get('start_time', time.time())
-            
-            # Prepare completion data
-            completion_data = {
-                'request_id': request_id,
-                'status': 'completed',
-                'translated_text': worker_response.get('translated_text'),
-                'processing_time': processing_time,
-                'character_count': worker_response.get('character_count', len(job_data.get('text', ''))),
-                'translation_length': worker_response.get('translation_length', 0),
-                'from_cache': worker_response.get('from_cache', False),
-                'worker_name': worker.config.name,
-                'completed_at': datetime.now().isoformat()
-            }
-            
-            # Store in completed jobs
-            self.completed_jobs[request_id] = completion_data
-            
-            # Remove from active jobs
-            if request_id in self.active_jobs:
-                del self.active_jobs[request_id]
-            
-            # Notify WordPress if notification URL provided
-            notification_url = job_data.get('notification_url')
-            if notification_url:
-                self.notify_wordpress(notification_url, completion_data)
-    
+        """Handle successful job completion"""
+        worker = self.workers[worker_id]
+        
+        print(f"✅ Job {request_id} completed by {worker.config.name}")
+        
+        # Update worker stats
+        with self.worker_lock:
+            worker.active_jobs -= 1
+            worker.total_completed += 1
+        
+        # Get job data
+        job_info = self.active_jobs.get(request_id, {})
+        job_data = job_info.get('job_data', {})
+        
+        # Calculate processing time
+        processing_time = time.time() - job_info.get('start_time', time.time())
+        
+        # Prepare completion data
+        completion_data = {
+            'request_id': request_id,
+            'status': 'completed',
+            'translated_text': worker_response.get('translated_text'),
+            'processing_time': processing_time,
+            'character_count': worker_response.get('character_count', len(job_data.get('text', ''))),
+            'translation_length': worker_response.get('translation_length', 0),
+            'from_cache': worker_response.get('from_cache', False),
+            'worker_name': worker.config.name,
+            'completed_at': datetime.now().isoformat()
+        }
+        
+        # Store in completed jobs
+        self.completed_jobs[request_id] = completion_data
+        
+        # Remove from active jobs
+        if request_id in self.active_jobs:
+            del self.active_jobs[request_id]
+        
+        # Notify WordPress if notification URL provided
+        notification_url = job_data.get('notification_url')
+        if notification_url:
+            self.notify_wordpress(notification_url, completion_data)
+
     def handle_worker_failure(self, worker_id: str, request_id: str, error_message: str):
         """Handle job failure"""
         worker = self.workers[worker_id]
@@ -642,4 +637,4 @@ if __name__ == "__main__":
         host="0.0.0.0",
         port=port,
         log_level="info"
-    )            
+    )