Delete old backup directories. (#1722)

dkinzer · web-flow · commit 133f66c8288f · 2025-06-10T14:09:42.000-04:00
diff --git a/cob_datapipeline/backup_collections_dag.py b/cob_datapipeline/backup_collections_dag.py
@@ -50,7 +50,7 @@ def backup_collections(collections: list):
     delete_task = SSHOperator(
             task_id="delete_old_solr_backups",
             ssh_conn_id="SOLR_NETWORKED_DRIVE",
-            command="sudo find /backups/ -type f -mtime +30 -exec rm {} \\;",
+            command="sudo find /backups/ -type d -mindepth 1 -maxdepth 1 -mtime +30 -exec rm -rf {} +",
             cmd_timeout=None,
             )
 

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ def backup_collections(collections: list):`
`50`	`50`	`delete_task = SSHOperator(`
`51`	`51`	`task_id="delete_old_solr_backups",`
`52`	`52`	`ssh_conn_id="SOLR_NETWORKED_DRIVE",`
`53`		`- command="sudo find /backups/ -type f -mtime +30 -exec rm {} \\;",`
	`53`	`+ command="sudo find /backups/ -type d -mindepth 1 -maxdepth 1 -mtime +30 -exec rm -rf {} +",`
`54`	`54`	`cmd_timeout=None,`
`55`	`55`	`)`
`56`	`56`