a
    ;]rih  ã                   @   s   d Z ddlZddlmZmZ ddlZddlmZ ddl	m
Z
 ddlmZ ddlmZ ddlmZ d	ZdZdZdZdd
œdd„Zdd
œdd„ZdS )zccreate satbots table

Revision ID: 221e976a80af
Revises: 
Create Date: 2026-01-14 14:45:18.895002

é    N)ÚopÚcontext)ÚCONFIG)ÚEnumSqlalchemyType)ÚSatbotPriority)ÚSatbotState)Ú
SatbotTypeZ221e976a80af)Úreturnc                  C   s   t  dtjdt ¡ dddtjdttƒddtjdttƒddtjd	t ¡ ddtjd
t ¡ ddtjdttƒddtjdt 	t 
¡ ¡ddtjdt ¡ t d¡ddtjdt ¡ ddtjdt ¡ ddtjdt ¡ ddtjdt ¡ ddt d¡¡ t ¡ jjjj dd¡} tj tj td d | › d¡¡rœt  t dtd d › d| › d¡¡ t  ¡  t d¡¡ ¡ j}|d urœt  t d|d › ¡¡ d S )NÚsatbotsÚidFT)ÚnullableÚautoincrementÚtype)r   ÚstateZprogressÚpidÚpriorityÚlogZ
created_atz"TIMEZONE('utc', CURRENT_TIMESTAMP))Úserver_defaultr   Zcreated_by_idZ
started_atZfinished_atÚ
parametersÚappsZbackups_directoryz_satbots.csvzCOPY satbots FROM 'ú/z_satbots.csv' (FORMAT CSV)z!SELECT MAX(id) AS id FROM satbotsz+ALTER SEQUENCE satbots_id_seq RESTART WITH é   )r   Úcreate_tableÚsaÚColumnÚIntegerr   r   r   r   ÚARRAYÚStringÚ	TIMESTAMPÚtextÚJSONÚPrimaryKeyConstraintr   Úget_contextÚ
connectionÚengineÚurlÚdatabaseÚreplaceÚosÚpathÚexistsÚjoinr   ÚexecuteÚget_bindÚfetchoner   )r&   Zmax_id© r/   ú]/var/www/staging/api/app_home/migrations/satbots/alembic/versions/001_create_satbots_table.pyÚupgrade   s*    ó&&
r1   c                   C   s   t  d¡ d S )Nr
   )r   Ú
drop_tabler/   r/   r/   r0   Ú	downgrade3   s    r3   )Ú__doc__r(   Úalembicr   r   Ú
sqlalchemyr   Úsetupr   Z%main.services.custom_sqlalchemy_typesr   Z%main.services.satbots.satbot_priorityr   Z"main.services.satbots.satbot_stater   Z!main.services.satbots.satbot_typer   ÚrevisionÚdown_revisionÚbranch_labelsÚ
depends_onr1   r3   r/   r/   r/   r0   Ú<module>   s   