from futurehouse_client import FutureHouseClient, JobNames

# 初始化客户端
client = FutureHouseClient(
    api_key="your_api_key_here"
)

# 定义查询任务
task_data = {
    "name": JobNames.CROW,
    "query": "什么是CRISPR基因编辑技术的最新进展？"
}

# 执行查询并等待结果
response = client.run_tasks_until_done(task_data)
print(response.answer)

import asyncio
from futurehouse_client import FutureHouseClient, JobNames

async def main():
    client = FutureHouseClient(
        api_key="your_api_key_here"
    )
    
    task_data = {
        "name": JobNames.FALCON,
        "query": "免疫治疗在癌症治疗中的机制综述"
    }
    
    response = await client.arun_tasks_until_done(task_data)
    print(response.answer)
    return response

# 运行异步任务
result = asyncio.run(main())

import asyncio
from futurehouse_client import FutureHouseClient, JobNames

async def batch_query():
    client = FutureHouseClient(api_key="your_api_key_here")
    
    # 定义多个查询任务
    tasks = [
        {
            "name": JobNames.OWL,
            "query": "有人研究过纳米药物载体在脑部递送中的应用吗？"
        },
        {
            "name": JobNames.CROW,
            "query": "阿尔茨海默病的最新治疗方法有哪些？"
        }
    ]
    
    # 批量执行
    responses = await client.arun_tasks_until_done(tasks)
    
    for i, response in enumerate(responses):
        print(f"任务 {i+1} 结果: {response.answer}")

asyncio.run(batch_query())