[[workflows]]name = "daily_industry_briefing"description = "毎朝8時に前日の業界動向レポートを生成"[workflows.trigger]type = "schedule"cron = "0 8 * * 1-5"             # 平日の朝8時[[workflows.tasks]]id = "monitor"hand = "collector"config = { keywords = ["AI agent", "Rust framework"], sources = ["news", "github"] }timeout = 300[[workflows.tasks]]id = "summarize"hand = "researcher"config = { depth = "shallow", focus = "summary" }depends_on = ["monitor"]timeout = 600[[workflows.tasks]]id = "notify"channel = "slack"config = { channel = "#industry-news", format = "rich_text" }depends_on = ["summarize"][workflows.output]format = "slack_message"save_to = "workspace/briefings/{{date}}.md"

[[workflows]]name = "competitor_monitor"description = "5つの競合サイトを並列監視し、変更があればアラートを送信"[workflows.trigger]type = "schedule"cron = "0 */6 * * *"# ステージ 1: 並列収集（Fan-out）[[workflows.tasks]]id = "check_competitor_a"hand = "collector"config = { target = "competitor-a.com", mode = "diff" }[[workflows.tasks]]id = "check_competitor_b"hand = "collector"config = { target = "competitor-b.com", mode = "diff" }[[workflows.tasks]]id = "check_competitor_c"hand = "collector"config = { target = "competitor-c.com", mode = "diff" }# ステージ 2: 統合分析（全収集完了を待機）[[workflows.tasks]]id = "aggregate"hand = "researcher"config = { action = "merge_and_prioritize" }depends_on = ["check_competitor_a", "check_competitor_b", "check_competitor_c"]# ステージ 3: 条件判断 — 重要な変更がある場合のみ通知[[workflows.tasks]]id = "check_significance"hand = "predictor"config = { action = "assess_impact" }depends_on = ["aggregate"]# ステージ 4: 条件付き通知[[workflows.tasks]]id = "alert_high"channel = "telegram"config = { chat_id = "-100xxx", priority = "high" }depends_on = ["check_significance"]condition = "ctx.significance_score > 0.7"[[workflows.tasks]]id = "alert_low"channel = "email"config = { to = "[email protected]", priority = "low" }depends_on = ["check_significance"]condition = "ctx.significance_score <= 0.7"

[[workflows]]name = "content_pipeline"description = "トピックから公開までを全自動化するコンテンツ制作パイプライン"[workflows.trigger]type = "webhook"endpoint = "/webhook/content/new"secret = "${WEBHOOK_SECRET}"# ステージ 1: リサーチ[[workflows.tasks]]id = "research"hand = "researcher"config = {  depth = "deep",  source_types = ["academic", "news", "social"],  target_length = "3000_words"}timeout = 900# ステージ 2: 執筆（異なるモデルを使用）[[workflows.tasks]]id = "draft"hand = "researcher"              # Researcher Handを再利用し、異なるプロンプトを使用config = {  model = "claude-opus-4-8",  instruction = "draft_article",  style = "professional_yet_approachable"}depends_on = ["research"]# ステージ 3: 事実確認[[workflows.tasks]]id = "fact_check"hand = "researcher"config = {  model = "claude-haiku-4-5",   # 高速モデルでチェック  action = "verify_claims",  strictness = "high"}depends_on = ["draft"]# ステージ 4: 画像生成[[workflows.tasks]]id = "generate_cover"hand = "clip"config = {  action = "generate_cover_image",  style = "modern_tech",  resolution = "1280x720"}depends_on = ["draft"]           # 事実確認を待たずに並列実行可能# ステージ 5: SEO最適化[[workflows.tasks]]id = "seo_optimize"hand = "researcher"config = { action = "seo_optimize", target_keyword = "{{.keyword}}" }depends_on = ["fact_check"]# ステージ 6: 公開[[workflows.tasks]]id = "publish"channel = "webhook"config = { url = "{{.cms_endpoint}}", method = "POST" }depends_on = ["seo_optimize", "generate_cover"]# ステージ 7: プロモーション[[workflows.tasks]]id = "promote"channel = "twitter"config = { action = "post_thread", hashtags = ["#AI", "#Automation"] }depends_on = ["publish"]

[[workflows]]name = "support_triage"description = "インテリジェントなカスタマーサポート：分類 → ルーティング → 処理 → エスカレーション"[workflows.trigger]type = "message"channel = "whatsapp"pattern = "/help *"# 分類[[workflows.tasks]]id = "classify"hand = "researcher"config = {  model = "claude-haiku-4-5",  action = "classify_intent",  categories = ["billing", "technical", "feature_request", "complaint"]}# 請求関連 → システム照会[[workflows.tasks]]id = "handle_billing"channel = "webhook"config = { url = "https://billing-api.company.com/lookup" }depends_on = ["classify"]condition = "ctx.intent == 'billing'"# 技術関連 → ナレッジベース検索[[workflows.tasks]]id = "search_kb"hand = "researcher"config = { action = "search_knowledge_base", max_results = 3 }depends_on = ["classify"]condition = "ctx.intent == 'technical'"# 機能リクエスト → Product Boardへ記録[[workflows.tasks]]id = "log_feature"channel = "webhook"config = { url = "https://productboard-api.company.com/notes" }depends_on = ["classify"]condition = "ctx.intent == 'feature_request'"# クレーム → 即時有人対応へエスカレーション[[workflows.tasks]]id = "escalate"channel = "slack"config = { channel = "#urgent-support", mention = "@oncall" }depends_on = ["classify"]condition = "ctx.intent == 'complaint'"# 最終回答[[workflows.tasks]]id = "reply"channel = "whatsapp"config = { reply_to = "{{.original_message.id}}" }depends_on = ["handle_billing", "search_kb", "log_feature", "escalate"]

# Dry run（外部操作は実行されません）openfang workflow run competitor_monitor --dry-run# 指定したタスクまで実行openfang workflow run content_pipeline --until draft# ワークフロー実行履歴の確認openfang workflow history competitor_monitor --limit 10# 特定の実行ログの詳細確認openfang workflow inspect competitor_monitor --run-id abc123