Purge old data hourly.

app.py

@@ -3,5 +3,5 @@ During development, to mimic the same behavior as on Hugging Face Spaces.
 PROMPT> IS_HUGGINGFACE_SPACES=true python app.py
 """
 if __name__ == "__main__":
-    from src.plan.app_text2plan import demo_text2plan
-    demo_text2plan.launch()
+    from src.plan.app_text2plan import run_app_text2plan
+    run_app_text2plan()

src/plan/app_text2plan.py

@@ -20,6 +20,7 @@ from src.plan.filenames import FilenameEnum
 from src.plan.plan_file import PlanFile
 from src.plan.speedvsdetail import SpeedVsDetailEnum
 from src.prompt.prompt_catalog import PromptCatalog
+from src.purge.purge_old_runs import start_purge_scheduler
 from src.utils.get_env_as_string import get_env_as_string
 from src.utils.is_huggingface_spaces import is_huggingface_spaces
 from src.utils.time_since_last_modification import time_since_last_modification
@@ -33,16 +34,19 @@ class Config:
     use_uuid_as_run_id: bool
     visible_open_output_dir_button: bool
     allow_only_openrouter_models: bool
+    enable_purge_old_runs: bool
 
 CONFIG_LOCAL = Config(
     use_uuid_as_run_id=False,
     visible_open_output_dir_button=True,
     allow_only_openrouter_models=False,
+    enable_purge_old_runs=False,
 )
 CONFIG_HUGGINGFACE_SPACES = Config(
     use_uuid_as_run_id=True,
     visible_open_output_dir_button=False,
     allow_only_openrouter_models=True,
+    enable_purge_old_runs=True,
 )
 
 CONFIG = CONFIG_HUGGINGFACE_SPACES if IS_HUGGINGFACE_SPACES else CONFIG_LOCAL
@@ -481,8 +485,14 @@ with gr.Blocks(title="PlanExe") as demo_text2plan:
         outputs=[openrouter_api_key_text, model_radio, speedvsdetail_radio, session_state]
     )
 
-if __name__ == "__main__":
+def run_app_text2plan():
+    if CONFIG.enable_purge_old_runs:
+        start_purge_scheduler(run_dir=os.path.abspath(RUN_DIR), purge_interval_seconds=60*60, prefix=RUN_ID_PREFIX)
+
     # print("Environment variables Gradio:\n" + get_env_as_string() + "\n\n\n")
 
     print("Press Ctrl+C to exit.")
     demo_text2plan.launch()
+
+if __name__ == "__main__":
+    run_app_text2plan()

src/purge/purge_old_runs.py

@@ -39,11 +39,11 @@ def purge_old_runs(run_dir: str, max_age_hours: float = 1.0, prefix: str = "myru
         except Exception as e:
             logger.error(f"Error processing {item} in {run_dir}: {e}")
 
-def start_purge_scheduler(run_dir: str, purge_interval_seconds: float=3600, prefix: str = "myrun_") -> None:
+def start_purge_scheduler(run_dir: str, purge_interval_seconds: float = 3600, prefix: str = "myrun_") -> None:
     """
     Start the purge scheduler in a background thread.
     """
-    logger.info(f"Starting purge scheduler for {run_dir} every {purge_interval_seconds} seconds...")
+    logger.info(f"Starting purge scheduler for {run_dir} every {purge_interval_seconds} seconds. Prefix: {prefix}")
 
     if not os.path.isabs(run_dir):
         raise ValueError(f"run_dir must be an absolute path: {run_dir}")