
    lj                     4    d dl mZm Z mZ d dlmZ ddZddZy)    )UTCdatetime	timedelta)WatcherRepositoryNc                    t        |       }t        j                  t              t	        d      z
  j                         j                  dd      }| j                  dddd|df       | j                          |j                  d	d
d
dddd      }|d   dk(  sJ | j                  d      j                         d   dk(  sJ y )N  days+00:00Z^INSERT INTO watcher_events(event_type,severity,message,created_at,component) VALUES(?,?,?,?,?)testinfoold      Z   job_observationsjob_runsstatus_eventscollector_runswatcher_eventsTdry_runr      #SELECT COUNT(*) FROM watcher_eventsr   r   r   nowr   r   	isoformatreplaceexecutecommit	retentionfetchone)
connection
repositoryr   countss       tests/unit/test_retention.py&test_retention_dry_run_does_not_deleter*      s    ":.J<<yc22
=
=
?
G
GRU
VCwsF;=!!rs]`572#OX\ " ^F"#q(((CDMMOPQRVWWWW    c                 p   t        |       }t        j                  t              t	        d      z
  j                         j                  dd      }| j                  dddd|df       | j                          |j                  d	d
d
dddd       | j                  d      j                         d   dk(  sJ y )Nr   r	   r   r   r   r   r   r   r   r   r   r   Fr   r   r   r   )r&   r'   r   s      r)   .test_retention_apply_deletes_old_watcher_eventr-      s    ":.J<<yc22
=
=
?
G
GRU
VCwsF;=bcTW,."FOT  VCDMMOPQRVWWWWr+   )returnN)r   r   r   worker_watcher.db.repositoriesr   r*   r-    r+   r)   <module>r1      s    - - <	XXr+   