Function continue_processing

agent/batch_manager.py:124–148

继续处理中断的任务

(recipe_dir: str, output_dir: str)

        print(f"❌ 合并失败: {str(e)}")

def continue_processing(recipe_dir: str, output_dir: str):
    """继续处理中断的任务"""
    config = load_config()
    api_key = config["openai"].get("api_key")
    
    if not api_key:
        print("❌ 未找到API密钥配置")
        return
    
    try:
        ai_agent = LLMRecipeAgent(api_key)
        batch_size = config.get("processing", {}).get("batch_size", 20)
        builder = RecipeKnowledgeGraphBuilder(ai_agent, output_dir, batch_size)
        
        print("继续处理中断的任务...")
        processed, failed = builder.batch_process_recipes(recipe_dir, resume=True)

        print(f"处理完成: 总数 {processed}, 失败 {failed}")

        # 自动合并数据
        print("自动合并批次数据...")
        merge_batches(output_dir)
        
    except Exception as e:
        print(f"❌ 处理失败: {str(e)}")

def show_batch_details(output_dir: str, batch_num: int = None):
    """显示批次详细信息"""