diff --git a/api/core/app/engine_layers/timeslice_layer.py b/api/core/app/engine_layers/timeslice_layer.py index de5129de55..9c23528714 100644 --- a/api/core/app/engine_layers/timeslice_layer.py +++ b/api/core/app/engine_layers/timeslice_layer.py @@ -13,7 +13,7 @@ from services.workflow.scheduler import CFSPlanScheduler, SchedulerCommand logger = logging.getLogger(__name__) -class TimesliceLayer(GraphEngineLayer): +class TimeSliceLayer(GraphEngineLayer): """ CFS plan scheduler to control the timeslice of the workflow. """ @@ -25,8 +25,8 @@ class TimesliceLayer(GraphEngineLayer): CFS plan scheduler allows to control the timeslice of the workflow. """ - if not TimesliceLayer.scheduler.running: - TimesliceLayer.scheduler.start() + if not TimeSliceLayer.scheduler.running: + TimeSliceLayer.scheduler.start() super().__init__() self.cfs_plan_scheduler = cfs_plan_scheduler diff --git a/api/tasks/async_workflow_tasks.py b/api/tasks/async_workflow_tasks.py index 14b289a6a7..111d2dee0c 100644 --- a/api/tasks/async_workflow_tasks.py +++ b/api/tasks/async_workflow_tasks.py @@ -13,7 +13,7 @@ from sqlalchemy import select from sqlalchemy.orm import Session, sessionmaker from core.app.apps.workflow.app_generator import WorkflowAppGenerator -from core.app.engine_layers.timeslice_layer import TimesliceLayer +from core.app.engine_layers.timeslice_layer import TimeSliceLayer from core.app.engine_layers.trigger_post_layer import TriggerPostLayer from core.app.entities.app_invoke_entities import InvokeFrom from extensions.ext_database import db @@ -140,7 +140,7 @@ def _execute_workflow_common( triggered_from=trigger_data.trigger_type, root_node_id=trigger_data.root_node_id, layers=[ - TimesliceLayer(cfs_plan_scheduler), + TimeSliceLayer(cfs_plan_scheduler), TriggerPostLayer(cfs_plan_scheduler_entity, start_time, trigger_log.id), ], )