Add rerun for savedsearch

contentctl/objects/correlation_search.py

@@ -36,7 +36,7 @@
 # Suppress logging by default; enable for local testing
 ENABLE_LOGGING = True
 LOG_LEVEL = logging.DEBUG
-LOG_PATH = "correlation_search.log"
+LOG_PATH = "correlation_search_test2.log"
 
 
 class SavedSearchKeys(StrEnum):
@@ -934,10 +934,10 @@
 
         # keep track of time slept and number of attempts for exponential backoff (base 2)
         elapsed_sleep_time = 0
         num_tries = 0
 
         # set the initial base sleep time
         time_to_sleep = TimeoutConfig.BASE_SLEEP
 
         try:
             # first make sure the indexes are currently empty and the detection is starting from a disabled state
@@ -1004,7 +1004,7 @@
                     current_turn += 1
 
                     self.logger.info(
                         f"Skipping sleeping time for testing purposes"
                     )
 
                     if current_turn > 3:
@@ -1013,6 +1013,20 @@
                         self.logger.info(f"Waiting {wait_time}s before retry {current_turn}...")
 
                         wait_time = min(wait_time * 2, max_wait)
+
+                        # Rerun the search job
+                        job = self.dispatch()
+                        self.logger.info(f"Force running detection '{self.name}' with job ID: {job.sid}")
+
+                        time_to_execute = 0
+
+                        # Check if the job is finished
+                        while not job.is_done():
+                            self.logger.info(f"Job {job.sid} is still running...")
+                            time.sleep(1)
+                            time_to_execute += 1
+
+                        self.logger.info(f"Job {job.sid} has finished running in {time_to_execute} seconds.")
 
                     # reset the result to None on each loop iteration
                     result = None