"""
Worker entrypoint. In production this drains a queue of order jobs and runs the
compliant pipeline. For now it exposes a CLI to run a single job locally.
  python -m workers.run <order_id>
"""
from __future__ import annotations

import asyncio
import sys

from workers.pipeline import run_job


async def _main() -> None:
    order_id = sys.argv[1] if len(sys.argv) > 1 else "demo"
    result = await run_job(order_id, {"markets": ["NO", "GB"], "confidence": 90})
    print(result["metrics"])


if __name__ == "__main__":
    asyncio.run(_main())