Devin Dynamic Workflows

ワークフローを使って、jobs/ 配下のすべての job をレガシーな cron ランナーから
新しいスケジューラー API へ移行してください。job ごとに agent を 1 つ割り当て、
それぞれ専用のブランチで作業し、その job のテストを実行すること。最後に、手動対応が
必要な job を一覧にまとめてください

workflowを利用して、新しいイベントサービス向けにPostgres、DynamoDB、CockroachDBを
評価してください。選択肢ごとにagentを1つ割り当て、レイテンシ、コスト、運用要件に
照らしてスコアリングし、最後にagentを1つ立てて、evidenceを比較したうえで1つを推奨してください

ワークフローを使って、このブランチで変更されたすべてのファイルを CONTRIBUTING.md
に照らしてレビューして — ファイルごとにレビュアーを1人ずつ — その後、検出結果を
重複を排除した1つのリストにまとめ、重大度順に並べて

ワークフローを利用して、レポーティングモジュール内のすべてのSQLクエリを監査し、
ページネーションの欠落やN+1パターンを洗い出し、確認された各issueをそれぞれ
専用のブランチで修正し、修正の前後でEXPLAINを実行して各修正を検証してください

ワークフローを利用して、不安定な統合テストスイートをグリーンにしてください。テストを実行し、
失敗した箇所を修正し、3回連続で成功するか、1周しても新たに直せるものがなくなるまで
繰り返してください

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