from __future__ import annotations

from app.modules.agent.orchestration.context.execution_context import ExecutionContext


class BootstrapStep:
    async def run(self, context: ExecutionContext) -> None:
        context.trace.module("orchestrator").log(
            "bootstrap",
            {"status": "started", "process_version": context.request.process_version},
        )
        await context.publisher.publish_status(
            context.request.request_id,
            "orchestrator",
            "Запрос принят и поставлен в обработку.",
        )
        await context.publisher.publish_status(
            context.request.request_id,
            "orchestrator",
            "Запускаю процесс обработки v1.",
            {"process_version": context.request.process_version},
        )
        context.trace.module("orchestrator").log("bootstrap", {"status": "completed"})
