From fbeb35fbb595b8c2a33d2dac633cfaaa9ecc3de0 Mon Sep 17 00:00:00 2001 From: hjlarry Date: Wed, 17 Dec 2025 14:54:48 +0800 Subject: [PATCH] should be SANDBOX_EXPIRED_RECORDS_CLEAN_GRACEFUL_PERIOD --- api/configs/feature/__init__.py | 6 +++--- api/services/clear_free_plan_expired_workflow_run_logs.py | 2 +- .../test_clear_free_plan_expired_workflow_run_logs.py | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/api/configs/feature/__init__.py b/api/configs/feature/__init__.py index 8fea64b841..c270e17ccc 100644 --- a/api/configs/feature/__init__.py +++ b/api/configs/feature/__init__.py @@ -1152,12 +1152,12 @@ class CeleryScheduleTasksConfig(BaseSettings): ) -class SandboxRecordsCleanConfig(BaseSettings): - SANDBOX_RECORDS_CLEAN_GRACEFUL_PERIOD: NonNegativeInt = Field( +class SandboxExpiredRecordsCleanConfig(BaseSettings): + SANDBOX_EXPIRED_RECORDS_CLEAN_GRACEFUL_PERIOD: NonNegativeInt = Field( description="Graceful period in days for sandbox records clean after subscription expiration", default=21, ) - SANDBOX_RECORDS_CLEAN_BATCH_SIZE: PositiveInt = Field( + SANDBOX_EXPIRED_RECORDS_CLEAN_BATCH_SIZE: PositiveInt = Field( description="Maximum number of records to process in each batch", default=1000, ) diff --git a/api/services/clear_free_plan_expired_workflow_run_logs.py b/api/services/clear_free_plan_expired_workflow_run_logs.py index 6c17e9ddb4..ed829b853d 100644 --- a/api/services/clear_free_plan_expired_workflow_run_logs.py +++ b/api/services/clear_free_plan_expired_workflow_run_logs.py @@ -45,7 +45,7 @@ class WorkflowRunCleanup: self.batch_size = batch_size self.billing_cache: dict[str, TenantPlanInfo | None] = {} self.dry_run = dry_run - self.free_plan_grace_period_days = dify_config.SANDBOX_RECORDS_CLEAN_GRACEFUL_PERIOD + self.free_plan_grace_period_days = dify_config.SANDBOX_EXPIRED_RECORDS_CLEAN_GRACEFUL_PERIOD self.workflow_run_repo: APIWorkflowRunRepository if workflow_run_repo: self.workflow_run_repo = workflow_run_repo diff --git a/api/tests/unit_tests/services/test_clear_free_plan_expired_workflow_run_logs.py b/api/tests/unit_tests/services/test_clear_free_plan_expired_workflow_run_logs.py index aca7f6f669..c2cfcd9811 100644 --- a/api/tests/unit_tests/services/test_clear_free_plan_expired_workflow_run_logs.py +++ b/api/tests/unit_tests/services/test_clear_free_plan_expired_workflow_run_logs.py @@ -76,7 +76,7 @@ def create_cleanup( ) -> WorkflowRunCleanup: monkeypatch.setattr( cleanup_module.dify_config, - "SANDBOX_RECORDS_CLEAN_GRACEFUL_PERIOD", + "SANDBOX_EXPIRED_RECORDS_CLEAN_GRACEFUL_PERIOD", grace_period_days, ) return WorkflowRunCleanup(workflow_run_repo=repo, **kwargs)