Update utils/arxiv_utils.py

utils/arxiv_utils.py

@@ -333,11 +333,12 @@ async def process_arxiv_generate_subheadings(
     logger.info(f"review: {review_arxiv_df}")
     results, exceptions = await retry_operation(
         generate_subheadings, task,
-        relevant_papers_df=review_arxiv_df, main_topic = task.direction,
+        relevant_papers_df=review_arxiv_df, main_topic = task.query,
         uuid=uuid, customer_name=customer_name, model_name=save_name,
         max_retries=max_retries, delay=delay,
         chat_func=chat_func
     )
+    logger.info(f"results:{results}")
     if results is None: # no valid result after max retries
         task.status_string[model_name] = exceptions # store exception strings in status
         await upload_task_json_to_minio(task, client)