Update chat_service.py

Author: fengju0213

backend/app/service/chat_service.py

@@ -474,18 +474,22 @@ async def run_decomposition():
                             if stream_state["subtasks"]:
                                 sub_tasks = stream_state["subtasks"]
                             state_holder["sub_tasks"] = sub_tasks
+                            logger.info(f"[NEW-QUESTION] ✅ Task decomposed into {len(sub_tasks)} subtasks")
                             try:
                                 setattr(task_lock, "decompose_sub_tasks", sub_tasks)
                             except Exception:
                                 pass
 
+                            logger.info(f"[NEW-QUESTION] Generating task summary")
                             summary_task_agent = task_summary_agent(options)
                             try:
                                 summary_task_content = await asyncio.wait_for(
                                     summary_task(summary_task_agent, camel_task), timeout=10
                                 )
                                 task_lock.summary_generated = True
+                                logger.info("[NEW-QUESTION] ✅ Summary generated successfully", extra={"project_id": options.project_id})
                             except asyncio.TimeoutError:
+                                logger.warning("summary_task timeout", extra={"project_id": options.project_id, "task_id": options.task_id})
                                 task_lock.summary_generated = True
                                 fallback_name = "Task"
                                 content_preview = camel_task.content if hasattr(camel_task, "content") else ""
@@ -511,6 +515,8 @@ async def run_decomposition():
                                 setattr(task_lock, "summary_task_content", summary_task_content)
                             except Exception:
                                 pass
+                            logger.info(f"[NEW-QUESTION] 📤 Sending to_sub_tasks SSE to frontend (task card)")
+                            logger.info(f"[NEW-QUESTION] to_sub_tasks data: task_id={camel_task.id}, summary={summary_task_content[:50]}..., subtasks_count={len(camel_task.subtasks)}")
                             payload = {
                                 "project_id": options.project_id,
                                 "task_id": options.task_id,
@@ -520,6 +526,7 @@ async def run_decomposition():
                                 "summary_task": summary_task_content,
                             }
                             await task_lock.put_queue(ActionDecomposeProgressData(data=payload))
+                            logger.info(f"[NEW-QUESTION] ✅ to_sub_tasks SSE sent")
                         except Exception as e:
                             logger.error(f"Error in background decomposition: {e}", exc_info=True)