From 724796467182fd7fb43c45192f39995c74397353 Mon Sep 17 00:00:00 2001
From: mattl-netflix <63665634+mattl-netflix@users.noreply.github.com>
Date: Sat, 15 Apr 2023 15:08:09 -0700
Subject: [PATCH] Always TTL backups. (#1038)

---
 .../com/netflix/priam/backupv2/BackupV2Service.java   | 11 +++++------
 .../netflix/priam/backupv2/TestBackupV2Service.java   |  7 +++++--
 2 files changed, 10 insertions(+), 8 deletions(-)

diff --git a/priam/src/main/java/com/netflix/priam/backupv2/BackupV2Service.java b/priam/src/main/java/com/netflix/priam/backupv2/BackupV2Service.java
index 71591e408..b1b185f40 100644
--- a/priam/src/main/java/com/netflix/priam/backupv2/BackupV2Service.java
+++ b/priam/src/main/java/com/netflix/priam/backupv2/BackupV2Service.java
@@ -68,21 +68,20 @@ public void scheduleService() throws Exception {
             // restart.
             snapshotMetaTask.uploadFiles();
 
-            // Schedule the TTL service
-            TaskTimer timer =
-                    BackupTTLTask.getTimer(backupRestoreConfig, tokenRetriever.getRingPosition());
-            scheduleTask(scheduler, BackupTTLTask.class, timer);
-
             // Schedule the backup verification service
             scheduleTask(
                     scheduler,
                     BackupVerificationTask.class,
                     BackupVerificationTask.getTimer(backupRestoreConfig));
         } else {
-            scheduler.deleteTask(BackupTTLTask.JOBNAME);
             scheduler.deleteTask(BackupVerificationTask.JOBNAME);
         }
 
+        // Schedule the TTL service
+        TaskTimer timer =
+                BackupTTLTask.getTimer(backupRestoreConfig, tokenRetriever.getRingPosition());
+        scheduleTask(scheduler, BackupTTLTask.class, timer);
+
         // Start the Incremental backup schedule if enabled
         scheduleTask(
                 scheduler,
diff --git a/priam/src/test/java/com/netflix/priam/backupv2/TestBackupV2Service.java b/priam/src/test/java/com/netflix/priam/backupv2/TestBackupV2Service.java
index 064c26b8b..a287a394b 100644
--- a/priam/src/test/java/com/netflix/priam/backupv2/TestBackupV2Service.java
+++ b/priam/src/test/java/com/netflix/priam/backupv2/TestBackupV2Service.java
@@ -17,6 +17,7 @@
 
 package com.netflix.priam.backupv2;
 
+import com.google.common.truth.Truth;
 import com.google.inject.Guice;
 import com.google.inject.Injector;
 import com.netflix.priam.backup.AbstractBackup;
@@ -72,6 +73,8 @@ public void testBackupDisabled(
             {
                 backupRestoreConfig.getSnapshotMetaServiceCronExpression();
                 result = "-1";
+                backupRestoreConfig.getBackupTTLMonitorPeriodInSec();
+                result = 600;
                 configuration.getDataFileLocation();
                 result = "target/data";
             }
@@ -109,7 +112,7 @@ public void testBackupDisabled(
                         cassandraTunerService,
                         tokenRetriever);
         backupService.scheduleService();
-        Assert.assertTrue(scheduler.getScheduler().getJobGroupNames().isEmpty());
+        Truth.assertThat(scheduler.getScheduler().getJobGroupNames()).hasSize(1);
 
         // snapshot V2 name should not be there.
         Set<Path> backupPaths =
@@ -220,6 +223,6 @@ public void updateService(
         Assert.assertEquals(3, scheduler.getScheduler().getJobKeys(null).size());
 
         backupService.onChangeUpdateService();
-        Assert.assertEquals(0, scheduler.getScheduler().getJobKeys(null).size());
+        Assert.assertEquals(1, scheduler.getScheduler().getJobKeys(null).size());
     }
 }