פירוק משימות

# Prompt Chaining — fixed pipeline
async def code_review_pipeline(project_path: str):
    # Step 1: Always runs first — review each file
    file_reviews = []
    for file in get_project_files(project_path):
        review = await agent.run(
            f"Review this file for issues: {file}"
        )
        file_reviews.append(review)

    # Step 2: Always runs second — cross-file analysis
    summary = await agent.run(
        f"Analyze cross-file dependencies and issues: "
        f"{file_reviews}"
    )

    return summary

# Dynamic Decomposition — agent decides next steps
async def add_tests_dynamic(project_path: str):
    # Agent explores and adapts its plan
    result = await coordinator.run(
        f"Add comprehensive tests to {project_path}. "
        f"First map the project structure, identify critical "
        f"areas with no coverage, then build and adapt your "
        f"testing plan as you discover the codebase.",
        subagents=[
            analysis_agent,   # Maps structure
            test_writer,      # Writes tests
            test_runner,      # Validates tests pass
        ]
    )
    return result