
    iy                        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 dl
mZ d dlmZ  e       Zdefd	Zej#                  d
d eddd       eddd      ej$                  j&                  d       e	j(                  j+                  d
d eddd            j,                  dk(  r4ej/                  d
d eddd      gdej$                  j&                  d        ed       ej/                  dd eddd       eddd       eddd       eddd      gdej$                  j&                  d        ed       ej(                  j1                  d      j+                  dd       Zej(                  j+                  ej4                  !      Zej8                   edd"d#      k7  r" ed$ej<                   d%ej8                         ej8                  e_        ejA                  d&d'g(        ed       y))*    )date)AccountSyncLog)refresh_onboarding_run)SyncJobType)PipelineSyncStatus)AccountSyncService)Accountrun_idc                 R   t         j                  j                  d      j                  |       }t	        |      }t        |j                  |j                  |j                  |j                  |j                  |j                  |j                  |j                  |j                  	       y )Naccountid)r   objectsselect_relatedgetr   printr   
account_idoverall_statuscurrent_stagead_creative_sync_statusstats_sync_statusai_reports_statusstats_days_completedstats_days_total)r
   run	refresheds      !/tmp/repair_backfill_sync_runs.pyrefreshr      s    

 
 
/
/	
:
>
>&
>
IC&s+I	  ))####&&""
    z$5258b660-b3a1-4dfb-91f8-fc11faf32755z$263e7df2-09fb-4b7e-a17d-277298aed6efi  	   z$7908399c-fed9-4f88-933e-18220a31f34c)r   user_id
start_dateend_datejob_typeaccount_sync_log_idTIKTOK)r   platform	sync_dateSUCCESS)r   r!   datesr'   r$   r%   z$a0b185d4-d194-4cf5-b342-edf86a665d49z$eada60a0-9902-40c9-9afc-570db1c23514               FACEBOOKz$2bbacc00-76c3-4359-b9bd-08d4f92134e6r   z$773405ee-b863-49a7-8cac-79bb8249b04dz$fa86db9b-cb49-4cea-a9dc-083e0e69d1de)r   r   r         z!Unexpected first_synced_date for z: window_start
updated_at)update_fieldsN)!datetimer   creative_module.modelsr   +creative_module.services.onboarding_servicer   data_pipeline_module.constantsr   data_pipeline_module.modelsr   *data_pipeline_module.services.sync_servicer   organization_auth.modelsr	   servicestrr   sync_account_date_rangeBACKFILLvaluer   r   statussync_account_breakdownsr   r   r   r   first_synced_dateRuntimeErrorr   r3   save r   r   <module>rH      s"    1 N 6 : I , 
C $   52D!Q$1!!''>    !!54A "  	&I	
 ##96D!Q %%++B $  . /   52T1bT2qT2rT2r	 !!''>    . / ++I6::-5 ;  //



0
T1a 00

+GJJ<r':S:S9TU  ,,  5 6 . /r   