Dynamische Devin-Workflows

Nutze einen Workflow, um jeden Job in jobs/ vom Legacy-Cron-Runner auf unsere
neue Scheduler-API umzustellen — ein Agent pro Job, jeder auf einem eigenen Branch, der
die Tests des Jobs ausführt — und fasse anschließend zusammen, welche Jobs manuell nachbearbeitet werden müssen

Nutze einen Workflow, um Postgres, DynamoDB und CockroachDB für den neuen
Events-Dienst zu bewerten: ein Agent pro Option, der diese anhand unserer
Anforderungen an Latenz, Kosten und Betrieb bewertet, dann ein
abschließender Agent, der die Evidenz vergleicht und eine Option empfiehlt

Nutze einen Workflow, um jede in diesem Branch geänderte Datei anhand von
CONTRIBUTING.md zu reviewen — ein Reviewer pro Datei — und führe die Befunde
anschließend zu einer einzigen, nach Schweregrad sortierten Liste ohne
Duplikate zusammen

Nutze einen Workflow, um jede SQL-Query im Reporting-Modul auf fehlende
Paginierung und N+1-Muster zu prüfen, jedes bestätigte Problem in einem
eigenen Branch zu beheben und jede Korrektur mit einem EXPLAIN davor und
danach zu verifizieren

Nutze einen Workflow, um die instabile Integrationstest-Suite grün zu bekommen:
führe sie aus, korrigiere alles, was fehlgeschlagen ist, und wiederhole das so lange,
bis sie drei aufeinanderfolgende Runs besteht oder eine Runde nichts Neues mehr korrigiert

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())