
    qh                        d dl mZ d dlZd dlmZ d dlmZmZmZ d dlm	Z	 ddl
mZmZmZmZmZmZmZ  e	            ZddZddZddZdddZddZd Zedk    r e             dS dS )    )annotationsN)datetime)ListDictAny)
get_client   )start_batchfinish_batchingest_stagingseed_batch_as_newbuild_candidatesauto_decideapply_decisionsprefixstrreturnc                X    |  dt          j                                        d           S )N-z%Y%m%d-%H%M%S)r   nowstrftime)r   s    ./var/www/html/bot/app/sync2/run_sample_demo.pynow_idr      s*    AAx|~~..??AAA    List[Dict[str, Any]]c            	     B    dddddddiddd	d
ddddiddddddddidgS )NMOTIE	   김하나   산업정책실 산업혁신과	   사무관02-1234-0001notebaselinesourcename
departmentpositionphoneraw	   이지수   무역투자실 FTA정책과u	   서기관z02-1234-0002u	   박민호u   산업정책실 소재부품과u	   주무관z02-1234-0003 r-   r   r   sample_rows_v1r.      su     ;##J'	
 	
 8##J'	
 	
 ;##J'	
 	
# r   c            	     B    dddddddiddd	dd
dddiddddddddidgS )Nr   r   r,   r    r!   r"   zmoved departmentr$   r+   u   국장z02-9999-0002zpromoted + new phoneu	   최아라r   z02-1234-0004znew hirer-   r-   r   r   sample_rows_v2r0   5   sw     8##./	
 	
 8 #23	
 	
 ;##J'	
 	
) r   Fbatch_idrows	bootstrapboolc                Z   t          d|  d| d           t          |            t          | |           |rt          |            n!t	          |            t          | dd           t          |            t          | ddt          |          i	           t          d
|             d S )Nz[+] start batch: z (bootstrap=)g?g?)himargin	COMPLETEDr   )statussource_summaryz[+] finished batch: )	printr
   r   r   r   r   r   r   len)r1   r2   r3   s      r   	run_batchr>   X   s    	
@h
@
@I
@
@
@AAA8T""" 4(#### 	"""Hd3333H+wD		>RSSSS	
+
+
+,,,,,r   titlec                0   t          d|  d| d           t                              d                              d                              d|                              d                                          j        pg }|st          d           n|D ]}|                    d	          }|                    d
          }|                    d          }|                    d          pi }|                    d          pi }t          d|dd| d| d| d| 
           t                              d                              d                              d
                                          j        pg }	t          d           |	D ]}
t          |
d
         dd|
d          d|
d          d|
                    d           d|
                    d           d|
                    d           d|
                    d                      d S )Nz
=== z (batch_id=z) ===gov_staff_events*r1   event_idz(no events)
event_type	person_idr%   prevnextz- z<15z person_id=z source=z prev=z next=gov_staff_currentz%
--- gov_staff_current (snapshot) ---z>3 r&   z | r'   r(   r)   z
 | active=	is_active)	r<   sbtableselecteqorderexecutedataget)r?   r1   eveetpidsrcrF   nxtcurrs              r   print_summaryr[   g   s   	
45
4
4X
4
4
4555	$	%	%	,	,S	1	1	4	4Z	J	J	P	PQ[	\	\	d	d	f	f	k	qoqB 	Um 	U 	UA|$$B%%$$C%%//C55==&BD55==&BCSrSSS#SSsSS$SScSSTTTT
((&
'
'
.
.s
3
3
9
9+
F
F
N
N
P
P
U
[Y[C	
2333 _ _;  ^  ^  ^Qx[  ^  ^1V9  ^  ^|ATAT  ^  ^YZY^Y^_iYjYj  ^  ^opototu|o}o}  ^  ^  JK  JO  JO  P[  J\  J\  ^  ^  	_  	_  	_  	__ _r   c                     t          d          } t          | t                      d           t          d|            t          d          }t          |t	                      d           t          d|           d S )Nz	sample-v1T)r3   zAFTER V1z	sample-v2FzAFTER V2)r   r>   r.   r[   r0   )b1b2s     r   mainr_   z   sz    			Bb.""d3333*b!!! 
		Bb.""e4444*b!!!!!r   __main__)r   r   r   r   )r   r   )F)r1   r   r2   r   r3   r4   )r?   r   r1   r   )
__future__r   osr   typingr   r   r   app.services.supabase_servicer   pipeliner
   r   r   r   r   r   r   rK   r   r.   r0   r>   r[   r_   __name__r-   r   r   <module>rg      sn   " " " " " " 				       " " " " " " " " " " 4 4 4 4 4 4                  Z\\B B B B   8   F- - - - -_ _ _ _&	" 	" 	" zDFFFFF r   