Function finalize_deployment

app/workers/tasks/deployment.py:383–450

Finalizes a deployment, setting up aliases and updating Traefik config.

(ctx, deployment_id: str)

async def finalize_deployment(ctx, deployment_id: str):
    """Finalizes a deployment, setting up aliases and updating Traefik config."""
    settings = get_settings()
    redis_client = get_redis_client()
    service = DeploymentService()
    log_prefix = f"[DeployFinalize:{deployment_id}]"
    logger.info(f"{log_prefix} Finalizing deployment")

    queue: ArqRedis | None = ctx.get("redis") if isinstance(ctx, dict) else None

    async with AsyncSessionLocal() as db:
        deployment = None
        try:
            deployment = (
                await db.execute(
                    select(Deployment)
                    .options(joinedload(Deployment.project))
                    .where(Deployment.id == deployment_id)
                )
            ).scalar_one()

            if deployment.conclusion == "canceled":
                logger.info(
                    "%s Deployment already canceled; skipping finalize.", log_prefix
                )
                return

            await DeploymentService().setup_aliases(deployment, db, settings)
            await db.commit()

            # Update Traefik dynamic config
            try:
                await DeploymentService().update_traefik_config(
                    deployment.project,
                    db,
                    settings,
                    include_deployment_ids={deployment.id},
                )
            except Exception as e:
                logger.error(f"{log_prefix} Failed to update Traefik config: {e}")

            await service.update_status(
                db,
                deployment,
                status="completed",
                conclusion="succeeded",
                error=None,
                redis_client=redis_client,
            )

            # Cleanup inactive deployments
            queue: ArqRedis = ctx["redis"]
            await queue.enqueue_job(
                "cleanup_inactive_containers", deployment.project_id
            )
            logger.info(
                f"{log_prefix} Inactive deployments cleanup job queued for project {deployment.project_id}."
            )