Workflows dinâmicos do Devin

Use um workflow para migrar todo job em jobs/ do executor cron legacy para a
nossa nova API de scheduler — um agent por job, cada um trabalhando na própria
branch e rodando os testes do job — e depois consolide quais jobs precisam de
atenção manual

Use um workflow para avaliar Postgres, DynamoDB e CockroachDB para o novo
serviço de eventos: um agent por opção, pontuando cada uma frente aos nossos
requisitos de latência, custo e operação, e depois um agent final que compara as
evidências e recomenda uma delas

Use um workflow para revisar todos os arquivos alterados nesta branch com base no
CONTRIBUTING.md — um revisor por arquivo — e depois faça o merge dos resultados em uma
única lista sem duplicatas, ordenada por severidade

Use um workflow para auditar cada query SQL no module de relatórios em busca de
pagination ausente e patterns N+1, corrigir cada problema confirmado em uma
branch separada e verificar cada correção com um EXPLAIN antes e depois

Use um workflow para deixar verde a suíte instável de testes de integração:
execute-a, corrija o que falhou e repita até ela passar em três runs
consecutivos ou até uma rodada não corrigir nada de novo

import asyncio
import json

REPO = "github.com/acme/api"
MODULES = ["auth", "billing", "search"]

META = {
    "name": "error-handling-audit",
    "description": "Audit and fix error-handling bugs across api modules",
    "phases": [
        {"title": "analyze", "detail": "audit each module for error-handling bugs"},
        {"title": "fix", "detail": "fix confirmed issues and push a branch"},
    ],
}

FINDINGS_SCHEMA = {
    "type": "object",
    "properties": {
        "module": {"type": "string"},
        "issues": {"type": "array", "items": {"type": "string"}},
    },
    "required": ["module", "issues"],
}

FIX_SCHEMA = {
    "type": "object",
    "properties": {"branch": {"type": "string"}, "summary": {"type": "string"}},
    "required": ["branch", "summary"],
}

async def analyze(module):
    return await agent(
        f"In {REPO}, audit the '{module}' module for error-handling bugs. "
        "Report each issue as a one-line string.",
        phase="analyze",
        schema=FINDINGS_SCHEMA,
        label=f"analyze-{module}",
    )

async def fix(findings):
    if not findings["issues"]:
        return None
    return await agent(
        f"In {REPO}, fix these issues in the '{findings['module']}' module:\n"
        + json.dumps(findings["issues"], sort_keys=True)
        + "\nPush your work to a new git branch (do not open a PR) and "
        "report the branch name and a one-line summary.",
        phase="fix",
        schema=FIX_SCHEMA,
        label=f"fix-{findings['module']}",
    )

async def main():
    await register_workflow(META)
    results = await pipeline(MODULES, analyze, fix)
    for module, result in zip(MODULES, results):
        log(f"{module}: {result['branch'] if result else 'no fix needed/failed'}")

asyncio.run(main())