┌────────────────────────┐
                                  │  Antigravity / User    │
                                  └───────────┬────────────┘
                                              │
                                     (Tasks / Batches)
                                              ▼
                                 ┌─────────────────────────┐
                                 │    SwarmEngine (Core)   │
                                 │  - Asyncio Semaphore    │
                                 │  - Retry + Backoff      │
                                 │  - Run Logger           │
                                 └────────────┬────────────┘
                                              │
                       ┌──────────────────────┼──────────────────────┐
                       ▼                      ▼                      ▼
               ┌───────────────┐      ┌───────────────┐      ┌───────────────┐
               │   Worker #1   │      │   Worker #2   │      │   Worker #N   │
               └───────┬───────┘      └───────┬───────┘      └───────┬───────┘
                       │                      │                      │
                       └──────────────────────┼──────────────────────┘
                                              ▼
                                 ┌─────────────────────────┐
                                 │  Provider (fabrika)     │
                                 │  AsyncRouterClient      │
                                 │  veya AGYSession        │
                                 └─────────────────────────┘

Copy-Item .env.example .env

LOCAL_ROUTER_BASE_URL=http://localhost:20128/v1
LOCAL_ROUTER_API_KEY=your_local_key_here

DEFAULT_MODEL=all
FALLBACK_MODEL=ag/gemini-3.7-flash-medium

MAX_CONCURRENT_WORKERS=8
REQUEST_TIMEOUT_SECONDS=150
MAX_RETRIES=3
RETRY_DELAY_SECONDS=2

TASK_TIMEOUT_SECONDS=0
BATCH_TIMEOUT_SECONDS=0

SAVE_RUN_LOGS=true
RUNS_DIR=./runs
METRICS_LOG=./runs/metrics.jsonl

pip install -r requirements.txt

python -m ruff check .     # statik kontrol
python -m pytest           # 134 offline test, ağ veya router gerekmez

{
  "mcpServers": {
    "swarm-orchestrator": {
      "command": "python",
      "args": ["C:/Users/<you>/Desktop/GitHub/Public/SwarmOrchestrator/mcp/server.py"],
      "env": {
        "PYTHONPATH": "C:/Users/<you>/Desktop/GitHub/Public/SwarmOrchestrator"
      }
    }
  }
}

import asyncio
from core.swarm_engine import SwarmEngine
from core.task_models import SwarmTask

async def main():
    tasks = [
        SwarmTask(
            id="t1",
            title="Örnek",
            system_prompt="You are a precise assistant.",
            user_prompt="Reply with exactly: OK",
        )
    ]
    summary = await SwarmEngine(max_workers=4).run_batch(tasks=tasks)
    print(summary.completed_tasks, "/", summary.total_tasks)

asyncio.run(main())

from pathlib import Path
from workflows.translation_workflow import TranslationWorkflow

workflow = TranslationWorkflow()          # use_cache=True varsayılan
summary = await workflow.execute(files=[Path("ornek.tsx")])

# Klasör çevirisi (önce --dry-run ile planı görün)
python cli.py translate -i .\src\pages -o .\locales\en\pages --dry-run
python cli.py translate -i .\src\pages -o .\locales\en\pages -c 8

# JSON görev listesi
python cli.py run -t .\tasks.json -o .\out -c 4 --provider agy

# Belirli görevleri hiç çalıştırmadan atla (per-task cancel)
python cli.py run -t .\tasks.json --cancel task_3 --cancel task_7

python run_page_translations.py --input <kaynak> --output <hedef>

batch translate_1 @ 2026-09-27T09:04:44
  tasks      : 2 total | 2 completed | 0 failed | 0 cancelled
  wall clock : 0.02s
  provider   : mean 0.01s | p50 0.01s | p95 0.01s | max 0.01s
  per task   : mean 0.02s | p50 0.02s | p95 0.02s
  tokens     : 300 (in 200 / out 100)
  cost       : $0.0000 (incomplete: no rate configured for all)

SwarmOrchestrator/
├── cli.py                       # Terminal arayüzü: translate / run / models / info / serve
├── config/
│   └── settings.py              # Pydantic tabanlı merkezi ayarlar
├── core/
│   ├── client.py                # Async HTTP istemcisi + sağlayıcı fabrikası
│   ├── agy_session.py           # Kalıcı Antigravity CLI (agy) oturumu
│   ├── worker.py                # Görev yaşam döngüsü, adaptif timeout, retry, iptal
│   ├── swarm_engine.py          # Semafor, iptal API'si, batch motoru + run logger
│   ├── metrics.py               # Token/gecikme istatistikleri, JSONL maliyet logu
│   ├── pricing.py               # Model prefix'i ile fiyat eşleştirme
│   ├── task_models.py           # Tipli veri modelleri (Pydantic)
│   ├── sanitizer.py             # Markdown/konuşma temizliği
│   └── cache.py                 # SHA-256 tabanlı görev cache'i
├── workflows/
│   ├── base_workflow.py         # Soyut iş akışı şablonu
│   ├── translation_workflow.py  # Teknik çeviri iş akışı
│   └── generic_workflow.py      # Genel görev iş akışı
├── mcp/
│   └── server.py                # FastMCP sunucusu (6 araç)
├── tests/
│   ├── conftest.py              # Offline koruması + sahte istemci
│   ├── test_router_parser.py    # SSE/JSON ayrıştırma (offline)
│   ├── test_worker_retry.py     # Retry/backoff/iptal/maliyet (offline)
│   ├── test_engine.py           # Batch sayımı, eşzamanlılık, iptal (offline)
│   ├── test_metrics.py          # Yüzdelik, fiyat, JSONL log (offline)
│   ├── test_sanitizer.py        # Fence/önsöz temizliği (offline)
│   ├── test_cli.py              # Argüman/yol/çıkış kodu (offline)
│   └── test_agy_provider.py     # CANLI sağlayıcı testi (pytest dışı, gerçek model çağırır)
├── run_page_translations.py     # Geriye uyumlu sarmalayıcı -> cli.py translate
├── scripts/
│   └── sync_to_gemini.ps1       # Kanonik depoyu .gemini çalışma kopyasına yansıtır
├── archives/                    # Eski/arşivlenmiş kod
├── docs/
│   └── KNOWLEDGE.md             # Kalıcı teknik bilgi
├── runs/                        # Batch JSON + metrics.jsonl (git-ignored)
├── pyproject.toml               # ruff + pytest yapılandırması
├── AGENTS.md                    # Ajan kılavuzu
├── ARCHITECTURE.md              # Katmanlar ve veri akışı
├── CHANGELOG.md                 # Sürüm tarihçesi
├── ROADMAP.md                   # Hedef fazlar
├── .env.example
├── requirements.txt
└── LICENSE

# Önizleme (hiçbir şey kopyalanmaz)
powershell -ExecutionPolicy Bypass -File .\scripts\sync_to_gemini.ps1 -WhatIf

# Gerçek senkronizasyon
powershell -ExecutionPolicy Bypass -File .\scripts\sync_to_gemini.ps1