प्रगति

from dedalus_mcp import get_context, tool

@tool(description="Process files")
async def process_files(files: list[str]) -> str:
    ctx = get_context()

    for i, file in enumerate(files, start=1):
        await ctx.report_progress(i, total=len(files), message=f"Processing {file}")
        process_file(file)  # आपका कोड; यदि यह ब्लॉक करता है, तो ऑफलोड करें या इसे async बनाएं

    return f"Processed {len(files)} files"

await ctx.report_progress(
    progress=50,                 # वर्तमान प्रगति का मान
    total=100,                   # वैकल्पिक कुल (प्रतिशत के लिए)
    message="Halfway done...",   # वैकल्पिक स्थिति संदेश
)

from dedalus_mcp import get_context, tool

@tool(description="Download files")
async def download_files(urls: list[str]) -> dict:
    ctx = get_context()
    downloaded: list[str] = []

    for i, url in enumerate(urls, start=1):
        await ctx.report_progress(i - 1, total=len(urls), message=f"Downloading {url}")
        await ctx.info("Downloading", data={"url": url})

        path = await download(url)  # आपका कोड
        downloaded.append(path)

        await ctx.report_progress(i, total=len(urls))

    return {"files": downloaded}

from dedalus_mcp import get_context, tool

@tool(description="बड़े डेटासेट को प्रोसेस करें")
async def process_dataset(dataset_id: str) -> dict:
    ctx = get_context()

    await ctx.report_progress(0, total=100, message="डेटासेट लोड हो रहा है")
    data = load_dataset(dataset_id)  # आपका कोड
    await ctx.report_progress(30, total=100, message="डेटा ट्रांसफॉर्म हो रहा है")

    total_items = len(data)
    if total_items:
        for i, item in enumerate(data, start=1):
            # आइटम की प्रगति को 30..70 रेंज में मैप करें
            progress = 30 + int((i / total_items) * 40)
            await ctx.report_progress(progress, total=100)
            transform(item)  # आपका कोड

    await ctx.report_progress(70, total=100, message="परिणाम सेव हो रहे हैं")
    save_results(data)  # आपका कोड
    await ctx.report_progress(100, total=100, message="पूर्ण हुआ")

    return {"processed": len(data)}

from dedalus_mcp import get_context, tool

@tool(description="Search until found")
async def search(query: str) -> str:
    ctx = get_context()
    pages_searched = 0

    while True:
        pages_searched += 1
        await ctx.report_progress(pages_searched, message=f"Searched {pages_searched} pages")

        result = search_page(query, pages_searched)  # आपका कोड
        if result:
            return result

        if pages_searched > 100:
            return "Not found"