File tree Expand file tree Collapse file tree 1 file changed +14
-19
lines changed Expand file tree Collapse file tree 1 file changed +14
-19
lines changed Original file line number Diff line number Diff line change @@ -233,24 +233,19 @@ def _delete_old_logs_job():
233233 # Get all logs older than 15 days
234234 date_to_delete_before = datetime .now (UTC ) - timedelta (days = 15 )
235235 count = get_count (date_to_delete_before )
236- with logfire .span (
237- 'Deleting {count=} webhooks before {date_to_delete_before=}' ,
238- date_to_delete_before = date_to_delete_before ,
239- count = count ,
240- ):
241- delete_limit = 4999
242- while count > 0 :
243- app_logger .info (f'Deleting { count } logs' )
244- logs_to_delete = db .exec (
245- select (WebhookLog ).where (WebhookLog .timestamp < date_to_delete_before ).limit (delete_limit )
246- ).all ()
247- delete_statement = delete (WebhookLog ).where (WebhookLog .id .in_ (log .id for log in logs_to_delete ))
248- db .exec (delete_statement )
249- db .commit ()
250- count -= delete_limit
251-
252- del logs_to_delete
253- del delete_statement
254- gc .collect ()
236+ delete_limit = 4999
237+ while count > 0 :
238+ app_logger .info (f'Deleting { count } logs' )
239+ logs_to_delete = db .exec (
240+ select (WebhookLog ).where (WebhookLog .timestamp < date_to_delete_before ).limit (delete_limit )
241+ ).all ()
242+ delete_statement = delete (WebhookLog ).where (WebhookLog .id .in_ (log .id for log in logs_to_delete ))
243+ db .exec (delete_statement )
244+ db .commit ()
245+ count -= delete_limit
246+
247+ del logs_to_delete
248+ del delete_statement
249+ gc .collect ()
255250
256251 cache .delete (DELETE_JOBS_KEY )
You can’t perform that action at this time.
0 commit comments