From f96bd4eb1854c01275eb10bf519330eb88e2d379 Mon Sep 17 00:00:00 2001 From: hjlarry Date: Thu, 2 Oct 2025 00:24:32 +0800 Subject: [PATCH] move schedule service to trigger sub dir --- .../event_handlers/sync_workflow_schedule_when_app_published.py | 2 +- api/services/{ => trigger}/schedule_service.py | 0 api/tasks/workflow_schedule_tasks.py | 2 +- api/tests/unit_tests/libs/test_cron_compatibility.py | 2 +- api/tests/unit_tests/services/test_schedule_service.py | 2 +- 5 files changed, 4 insertions(+), 4 deletions(-) rename api/services/{ => trigger}/schedule_service.py (100%) diff --git a/api/events/event_handlers/sync_workflow_schedule_when_app_published.py b/api/events/event_handlers/sync_workflow_schedule_when_app_published.py index 928ce60bd2..ddbb8479d1 100644 --- a/api/events/event_handlers/sync_workflow_schedule_when_app_published.py +++ b/api/events/event_handlers/sync_workflow_schedule_when_app_published.py @@ -8,7 +8,7 @@ from core.workflow.nodes.trigger_schedule.entities import SchedulePlanUpdate from events.app_event import app_published_workflow_was_updated from extensions.ext_database import db from models import AppMode, Workflow, WorkflowSchedulePlan -from services.schedule_service import ScheduleService +from services.trigger.schedule_service import ScheduleService logger = logging.getLogger(__name__) diff --git a/api/services/schedule_service.py b/api/services/trigger/schedule_service.py similarity index 100% rename from api/services/schedule_service.py rename to api/services/trigger/schedule_service.py diff --git a/api/tasks/workflow_schedule_tasks.py b/api/tasks/workflow_schedule_tasks.py index 17f4e0751c..da8dbfe3fa 100644 --- a/api/tasks/workflow_schedule_tasks.py +++ b/api/tasks/workflow_schedule_tasks.py @@ -14,7 +14,7 @@ from extensions.ext_database import db from models.enums import WorkflowRunTriggeredFrom from models.workflow import WorkflowSchedulePlan from services.async_workflow_service import AsyncWorkflowService -from services.schedule_service import ScheduleService +from services.trigger.schedule_service import ScheduleService from services.workflow.entities import TriggerData logger = logging.getLogger(__name__) diff --git a/api/tests/unit_tests/libs/test_cron_compatibility.py b/api/tests/unit_tests/libs/test_cron_compatibility.py index 9e5b99e940..6f3a94f6dc 100644 --- a/api/tests/unit_tests/libs/test_cron_compatibility.py +++ b/api/tests/unit_tests/libs/test_cron_compatibility.py @@ -295,7 +295,7 @@ class TestFrontendBackendIntegration(unittest.TestCase): def test_schedule_service_integration(self): """Test integration with ScheduleService patterns.""" from core.workflow.nodes.trigger_schedule.entities import VisualConfig - from services.schedule_service import ScheduleService + from services.trigger.schedule_service import ScheduleService # Test enhanced syntax through visual config conversion visual_configs = [ diff --git a/api/tests/unit_tests/services/test_schedule_service.py b/api/tests/unit_tests/services/test_schedule_service.py index c342af7a26..cd94ccd5bc 100644 --- a/api/tests/unit_tests/services/test_schedule_service.py +++ b/api/tests/unit_tests/services/test_schedule_service.py @@ -13,7 +13,7 @@ from events.event_handlers.sync_workflow_schedule_when_app_published import ( from libs.schedule_utils import calculate_next_run_at, convert_12h_to_24h from models.account import Account, TenantAccountJoin from models.workflow import Workflow, WorkflowSchedulePlan -from services.schedule_service import ScheduleService +from services.trigger.schedule_service import ScheduleService class TestScheduleService(unittest.TestCase):