o i@sUdZddlmZmZddlmZddlZddlmZdZ e e d<dZ ee dfe d <dZ ee ee dfe d <dZee ee dfe d <dd dZdddZdS)zpadd model_id to agents Revision ID: f6e5d4c3b2a1 Revises: a1b2c3d4e5f6 Create Date: 2026-03-28 18:00:00+08:00 )SequenceUnion)opN)inspect f6e5d4c3b2a1revision a1b2c3d4e5f6 down_revision branch_labels depends_onreturnc Cst}t|}dd|dD}d|vr:tdtjdtddtjddddgd gdd d t d ddgd |vrEt ddSdS)NcSh|]}|dqSname.0columnrrU/lsinfo/ai/hellotax_ai/base_platform/alembic/versions/20260328_1800_agent_model_id.py zupgrade..agentsmodel_idT)nullablefk_agents_model_id_modelsmodelsidpublic) source_schemareferent_schemaix_agents_model_idorchestrator_modela, UPDATE agents SET model_id = models.id FROM public.models WHERE agents.model_id IS NULL AND ( agents.orchestrator_model = models.name OR agents.orchestrator_model = models.code ) ) rget_bindr get_columns add_columnsaColumnIntegercreate_foreign_key create_indexexecute)bind inspectorcolumnsrrrupgrades( r.cCst}t|}dd|dD}d|vrIdd|dD}d|vr+tjddddd|dD}d |vrAtjd dd d tdddSdS) NcSr rrrrrrr9rzdowngrade..rrcSr rr)rindexrrrr<rr ) table_namecSsh|] }|dr|dqSr)get)rfkrrrr?sr foreignkey)type_) rr"rr# get_indexes drop_indexget_foreign_keysdrop_constraint drop_column)r+r,r-indexes foreign_keysrrr downgrade6sr<)r N)__doc__typingrralembicr sqlalchemyr%rrstr__annotations__r r r r.r<rrrrs    !