Ri F d dl mZ d dlmZ d dlmZ G d de ZdS ) ) MessageSink)db)recurring_checkc 6 e Zd ZdZdZeeddZd Zd Zd Z dS )
CheckpointzU
Checkpoint imunify360.db periodically to limit unexpected WAL file growing.
iQ )checkpoint_periodr c 0 || _ || _ d | _ d S N)_checkpoint_period_db_task)selfr r s W/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/plugins/checkpoint.py__init__zCheckpoint.__init__
s "3
c K || _ | j t | j | j | _ d S r
)_loop create_taskr r _checkpointr
)r loops r create_sinkzCheckpoint.create_sink sN
Z++ F 4OD 3 4 4T5E F F H H
r c K | j d c}| _ || rd S | | d {V d S r
)r
cancelledcancel)r tasks r shutdownzCheckpoint.shutdown sP :tdj <4>>++< F
r c > K | j d d S )Nz PRAGMA wal_checkpoint(TRUNCATE))r execute_sql)r s r r zCheckpoint._checkpoint s%
>?????r N)
__name__
__module__ __qualname____doc__ONE_DAYr r r r r r r r r su G,3
@ @ @ @ @r r N)!defence360agent.contracts.pluginsr defence360agent.model.instancer defence360agent.utilsr r r$ r r r( sy 9 9 9 9 9 9 - - - - - - 1 1 1 1 1 1 @ @ @ @ @ @ @ @ @ @r