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):