
    6i                         U d Z ddlmZmZ ddlmZ ddlZddlm	Z	 dZ
eed<   dZeedf   ed	<   dZeeee   df   ed
<   dZeeee   df   ed<   ddZddZy)zfdata import

Revision ID: ab7d891ce372
Revises: be92d0addc3f
Create Date: 2025-12-08 15:15:38.015218

    )SequenceUnion)opN)
postgresqlab7d891ce372revisionbe92d0addc3fdown_revisionbranch_labels
depends_onc                  V   t        j                  dt        j                  dt        j                         d      t        j                  dt        j
                  d      d      t        j                  dt        j
                  d	      d
      t        j                  dt        j
                  d      d      t        j                  dt        j                         d
      t        j                  dt        j                         d
      t        j                  dt        j                         d
      t        j                  dt        j                         d
      t        j                  dt        j
                  d      d
      t        j                  dt        j                  d
      t        j                  d      d      t        j                  dt        j                  d
      d
      t        j                  dt        j                         d
      t        j                  dt        j                         d
      t        j                  dt        j                         d
      t        j                  dt        j                  d
      t        j                  d      d      t        j                  dt        j                  d
      t        j                  d      d      t        j                  d             t        j                  t        j                  d      ddgd       t        j                  t        j                  d      ddgd       t        j                  t        j                  d      ddgd       t        j                  d d!"       t        j                  d#d!"       t        j                  d!       t        j                  d$d%"       t        j                  d&d%"       t        j                  d'd%"       t        j                  d%       y )(Nsmart_inventory_cron_job_logsidF)nullable	task_typed   lengthtask_id   Tstatus2   processed_countinserted_countupdated_countrows_insertedtarget_date
started_attimezonenow())server_defaultr   completed_atduration_secondserror_messagetask_result
created_at
updated_at#ix_smart_inventory_cron_job_logs_idunique(ix_smart_inventory_cron_job_logs_task_id*ix_smart_inventory_cron_job_logs_task_typeix_product_fetch_cron_logs_idproduct_fetch_cron_logs
table_name"ix_product_fetch_cron_logs_task_idix_cron_job_logs_idcron_job_logsix_cron_job_logs_task_idix_cron_job_logs_task_type)r   create_tablesaColumnIntegerStringDateTimetextTextJSONPrimaryKeyConstraintcreate_indexf
drop_index
drop_table     H/var/www/html/hubwallet-dev/alembic/versions/ab7d891ce372_data_import.pyupgraderH      s   OO3IIdBJJL51IIk299C05AIIi#.>IIh		,u=II=II

t<IIorzz|d;IIorzz|d;IImRYYb1DAIIlBKK6rwwwGWbghIInbkk484HII "**,>IIorwwy48IImRWWY6IIlBKK6rwwwGWbghIIlBKK6rwwwGWbghD!#& OOBDD>?A`cgbhqvwOOBDDCDFehqgr  |A  BOOBDDEFHgjuiv  @E  FMM1>WXMM6C\]MM+,MM'ODMM,IMM.?KMM/"rF   c                     t        j                  dt        j                  dt        j                         dd      t        j                  dt        j
                  d      dd      t        j                  d	t        j
                  d
      dd      t        j                  dt        j
                  d      dd      t        j                  dt        j                         dd      t        j                  dt        j                         dd      t        j                  dt        j                         dd      t        j                  dt        j                         dd      t        j                  dt        j
                  d      dd      t        j                  dt        j                  d      t        j                  d      dd      t        j                  dt        j                  d      dd      t        j                  dt        j                         dd      t        j                  dt        j                         dd      t        j                  dt        j                  t        j                               dd      t        j                  dt        j                  d      t        j                  d      dd      t        j                  dt        j                  d      t        j                  d      dd      t        j                  dd             t        j                  dddgd        t        j                  d!dd	gd        t        j                  d"ddgd        t        j                  d#t        j                  dt        j                         dd      t        j                  d	t        j
                  d
      dd      t        j                  dt        j
                  d      dd      t        j                  d$t        j                         dd      t        j                  d%t        j                         dd      t        j                  d&t        j                         dd      t        j                  d't        j                         dd      t        j                  d(t        j                         dd      t        j                  d)t        j                         dd      t        j                  dt        j                  d      t        j                  d      dd      t        j                  dt        j                  d      dd      t        j                  dt        j                         dd      t        j                  dt        j                         dd      t        j                  dt        j                  t        j                               dd      t        j                  dt        j                  d      t        j                  d      dd      t        j                  dt        j                  d      t        j                  d      dd      t        j                  dd*             t        j                  d+d#d	gd        t        j                  d,d#dgd        t        j                  t        j                  d-      d./       t        j                  t        j                  d0      d./       t        j                  t        j                  d1      d./       t        j                   d.       y )2Nr4   r   TF)autoincrementr   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r!   )r"   rJ   r   r#   r$   r%   r&   )astext_typer'   r(   cron_job_logs_pkey)namer6   r*   r5   r3   r/   
company_idtotal_pages	page_sizetotal_itemsprocessed_itemserror_countproduct_fetch_cron_logs_pkeyr2   r.   r-   r   r0   r,   r)   )r   r7   r8   r9   INTEGERVARCHARr   	TIMESTAMPr=   TEXTr?   r>   r@   rA   rC   rB   rD   rE   rF   rG   	downgraderY   7   s   OOOIIdBJJLuEIIk2::S1QVWIIi3/utTIIh

"-UUSIIUTRII

EDQIIorzz|54PIIorzz|54PIImRZZr2%RVWIIlJ00$?PRPWPWX_P`pu  AF  GIInj22DAQVaefII "**,edSIIorwwyMIImZ__CSXcghIIlJ00$?PRPWPWX_P`pu  AF  GIIlJ00$?PRPWPWX_P`pu  AF  GD';<#& OO0/K=Y^_OO.)UZ[OO)?TF5QOO-IIdBJJLuEIIi3/utTIIh

"-UUSIIlBJJLNIImRZZ\OIIk2::<uuMIImRZZ\NIIUTRIImRZZ\NIIlJ00$?PRPWPWX_P`pu  AF  GIInj22DAQVaefII "**,edSIIorwwyMIImZ__CSXcghIIlJ00$?PRPWPWX_P`pu  AF  GIIlJ00$?PRPWPWX_P`pu  AF  GD'EF#& OO8:SV_U`inoOO35NQUPV_deMM"$$CDQpqMM"$$ABOnoMM"$$<=JijMM12rF   )returnN)__doc__typingr   r   alembicr   
sqlalchemyr8   sqlalchemy.dialectsr   r   str__annotations__r
   r   r   rH   rY   rE   rF   rG   <module>rb      sv    #   * # "0uS$Y 015uS(3--. 5.2
E#x}d*+ 2#D03rF   