Fix job ID mismatch in progress updates - use full job_id instead of...

Fix job ID mismatch in progress updates - use full job_id instead of job_id_int for database lookups

vidai/worker_analysis.py

@@ -189,7 +189,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
     # Send initial progress update
     if comm:
         progress_msg = Message('progress', f'progress_{job_id_int}', {
-            'job_id': job_id_int,
+            'job_id': job_id,
             'stage': 'initializing',
             'progress': 5,
             'message': 'Initializing analysis job',
@@ -211,7 +211,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
     # Send progress update after model loading
     if comm:
         progress_msg = Message('progress', f'progress_{job_id_int}', {
-            'job_id': job_id_int,
+            'job_id': job_id,
             'stage': 'model_loaded',
             'progress': 8,
             'message': f'Model {model_path.split("/")[-1]} loaded successfully'
@@ -240,7 +240,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
         # Send progress update for frame extraction
         if comm:
             progress_msg = Message('progress', f'progress_{job_id_int}', {
-                'job_id': job_id_int,
+                'job_id': job_id,
                 'stage': 'frame_extraction',
                 'progress': 10,
                 'message': f'Extracted {total_frames} frames'
@@ -258,7 +258,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
             if comm:
                 progress_percent = 10 + int(i / total_frames * 70)  # 10-80% for frame processing
                 progress_msg = Message('progress', f'progress_{job_id_int}', {
-                    'job_id': job_id_int,
+                    'job_id': job_id,
                     'stage': 'frame_analysis',
                     'progress': progress_percent,
                     'message': f'Processing frame {i+1}/{total_frames} at {ts:.1f}s'
@@ -267,7 +267,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
                 print(f"PROGRESS: Job {job_id_int} - {progress_percent}% - Processing frame {i+1}/{total_frames}")
 
             # Check for cancellation
-            if job_id_int and check_job_cancelled(job_id_int):
+            if job_id and check_job_cancelled(job_id):
                 if get_debug():
                     print(f"DEBUG: Job {job_id_int} cancelled during frame processing")
                 # Clean up and return cancelled message
@@ -295,7 +295,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
             if comm and (i + 1) % max(1, total_frames // 10) == 0:  # Update every 10% or at least every frame for small videos
                 progress_percent = 10 + int((i + 1) / total_frames * 70)
                 progress_msg = Message('progress', f'progress_{job_id_int}', {
-                    'job_id': job_id_int,
+                    'job_id': job_id,
                     'stage': 'frame_analysis',
                     'progress': progress_percent,
                     'message': f'Completed frame {i+1}/{total_frames} ({progress_percent}%)',
@@ -307,7 +307,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
             # Send ping every 30 seconds to keep connection alive
             if comm and (i + 1) % max(1, total_frames // (total_frames // 30 + 1)) == 0:
                 ping_msg = Message('ping', f'ping_{job_id_int}_{i+1}', {
-                    'job_id': job_id_int,
+                    'job_id': job_id,
                     'timestamp': time.time()
                 })
                 comm.send_message(ping_msg)
@@ -323,7 +323,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
         # Send progress update for summary generation
         if comm:
             progress_msg = Message('progress', f'progress_{job_id_int}', {
-                'job_id': job_id_int,
+                'job_id': job_id,
                 'stage': 'summary_generation',
                 'progress': 85,
                 'message': 'Generating video summary'
@@ -332,7 +332,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
             print(f"PROGRESS: Job {job_id_int} - 85% - Generating video summary")
 
         # Check for cancellation before summary
-        if job_id_int and check_job_cancelled(job_id_int):
+        if job_id and check_job_cancelled(job_id):
             if get_debug():
                 print(f"DEBUG: Job {job_id_int} cancelled before summary")
             return "Job cancelled by user", total_tokens
@@ -378,7 +378,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
         # Send final progress update
         if comm:
             progress_msg = Message('progress', f'progress_{job_id_int}', {
-                'job_id': job_id_int,
+                'job_id': job_id,
                 'stage': 'completed',
                 'progress': 100,
                 'message': 'Analysis completed'
@@ -395,7 +395,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
         # Send progress update for image analysis start
         if comm:
             progress_msg = Message('progress', f'progress_{job_id_int}', {
-                'job_id': job_id_int,
+                'job_id': job_id,
                 'stage': 'image_analysis',
                 'progress': 20,
                 'message': 'Starting image analysis'
@@ -404,7 +404,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
             print(f"PROGRESS: Job {job_id_int} - 20% - Starting image analysis")
 
         # Check for cancellation before processing image
-        if job_id_int and check_job_cancelled(job_id_int):
+        if job_id and check_job_cancelled(job_id):
             if get_debug():
                 print(f"DEBUG: Job {job_id_int} cancelled before image analysis")
             return "Job cancelled by user", total_tokens
@@ -412,7 +412,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
         # Send progress update before model inference
         if comm:
             progress_msg = Message('progress', f'progress_{job_id_int}', {
-                'job_id': job_id_int,
+                'job_id': job_id,
                 'stage': 'image_processing',
                 'progress': 50,
                 'message': 'Processing image with AI model'
@@ -428,7 +428,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
         # Send progress update for completion
         if comm:
             progress_msg = Message('progress', f'progress_{job_id_int}', {
-                'job_id': job_id_int,
+                'job_id': job_id,
                 'stage': 'finalizing',
                 'progress': 90,
                 'message': 'Finalizing analysis results'
@@ -439,7 +439,7 @@ def analyze_media(media_path, prompt, model_path, interval=10, job_id_int=None,
         # Send final progress update
         if comm:
             progress_msg = Message('progress', f'progress_{job_id_int}', {
-                'job_id': job_id_int,
+                'job_id': job_id,
                 'stage': 'completed',
                 'progress': 100,
                 'message': 'Image analysis completed successfully'