कई एजेंट्स को एक साथ चलाना (Orchestration)

from concurrent.futures import ThreadPoolExecutor

def call_model(prompt: str) -> str:
    # Placeholder. Plug in your provider here.
    return "[model answer to: " + prompt[:50] + "...]"

def worker(sub_task: str) -> str:
    # Each worker could run its own agent loop with its own narrow tools.
    return call_model("You are a research worker. Do only this, and reply "
                      "in at most 5 bullet points with sources: " + sub_task)

def orchestrate(goal: str) -> str:
    sub_tasks = [   # in real code, ask the model for this list as JSON
        "Price and validity of plan A",
        "Price and validity of plan B",
        "Price and validity of plan C",
    ]
    with ThreadPoolExecutor(max_workers=3) as pool:
        results = list(pool.map(worker, sub_tasks))
    notes = "\n".join(t + ": " + r for t, r in zip(sub_tasks, results))
    return call_model("Goal: " + goal + "\nWorker notes:\n" + notes +
                      "\nCombine into one short comparison. Say if anything is missing.")

print(orchestrate("Compare three mobile plans for a student"))