Method start_run

app/runtime_logging.py:96–121

(
        self,
        *,
        account_id: str,
        action: str,
        source: str = "",
        product_id: str = "",
        pay_type: str = "",
        details: dict[str, Any] | None = None,
    )

        (self.settings.runtime_logs_dir / "accounts").mkdir(parents=True, exist_ok=True)

    def start_run(
        self,
        *,
        account_id: str,
        action: str,
        source: str = "",
        product_id: str = "",
        pay_type: str = "",
        details: dict[str, Any] | None = None,
    ) -> FlowRun:
        run = FlowRun(
            run_id=self._make_run_id(),
            account_id=account_id,
            action=action.strip() or "flow",
            source=source.strip(),
            product_id=product_id.strip(),
            pay_type=pay_type.strip(),
        )
        self.log_event(
            run,
            stage="run",
            status="started",
            message=f"{run.action} started",
            details=details,
        )
        return run

    def finish_run(
        self,