Skip to content

Commit 5685b54

Browse files
harishm17claude
andcommitted
Add visible WARNING logs and exception handling for enqueue debugging
- Change INFO to WARNING logs with ***** markers for visibility - Add try-except around enqueue call to catch failures - Add full traceback logging - Will help identify why enqueue isn't working Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
1 parent e455d21 commit 5685b54

1 file changed

Lines changed: 12 additions & 8 deletions

File tree

ai-service/app/api/routes/jobs.py

Lines changed: 12 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ async def validate_material_job(payload: JobPayload):
119119

120120
# If validation succeeded, automatically trigger chunking
121121
if validation_result.status == "valid":
122-
logger.info(f"Material validated successfully, triggering chunking for {input_data.materialId}")
122+
logger.warning(f"***** Material validated successfully, triggering chunking for {input_data.materialId} *****")
123123

124124
# Get user_id and project_id from the current job
125125
current_job = await execute_one(
@@ -146,15 +146,19 @@ async def validate_material_job(payload: JobPayload):
146146
)
147147

148148
# Trigger the chunking job via Cloud Tasks
149-
logger.info(f"Created chunking job {chunking_job['id']} for material {input_data.materialId}")
149+
logger.warning(f"***** Created chunking job {chunking_job['id']} for material {input_data.materialId} *****")
150150

151151
# Enqueue the chunking job
152-
await enqueue_chunking_job(
153-
job_id=chunking_job['id'],
154-
material_id=input_data.materialId
155-
)
156-
157-
logger.info(f"Enqueued chunking job {chunking_job['id']}")
152+
try:
153+
await enqueue_chunking_job(
154+
job_id=chunking_job['id'],
155+
material_id=input_data.materialId
156+
)
157+
logger.warning(f"***** Enqueued chunking job {chunking_job['id']} successfully *****")
158+
except Exception as enqueue_error:
159+
logger.error(f"***** ENQUEUE FAILED: {type(enqueue_error).__name__}: {str(enqueue_error)} *****")
160+
import traceback
161+
logger.error(f"***** TRACEBACK: {traceback.format_exc()} *****")
158162

159163
logger.info(f"Completed material validation job: {payload.jobId}")
160164

0 commit comments

Comments
 (0)