kanshan/dify
1
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-02-16 16:04:42 +08:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

fix: typing

Browse Source
This commit is contained in:
Yeuoly 2025-10-22 11:55:26 +08:00
parent 7acbe981e2
commit c36173f5a9
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
api/core/app/engine_layers/timeslice_layer.py
View File

@ -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

4
api/tasks/async_workflow_tasks.py
View File

@ -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),
],
)