diff --git a/cli_d_wf.py b/cli_d_wf.py
index d0946c5..6ec37ec 100644
--- a/cli_d_wf.py
+++ b/cli_d_wf.py
@@ -1,7 +1,7 @@
 import argparse
 
 from config import load_config
-from worker.danmaku import do_workflow
+from workflow.worker import do_workflow
 
 if __name__ == '__main__':
     load_config()
diff --git a/controller/api/bilirecorder_blueprint.py b/controller/api/bilirecorder_blueprint.py
index 8318496..8a37585 100644
--- a/controller/api/bilirecorder_blueprint.py
+++ b/controller/api/bilirecorder_blueprint.py
@@ -10,7 +10,7 @@ from model import db
 from model.DanmakuClip import DanmakuClip
 from model.VideoClip import VideoClip
 from model.Workflow import Workflow
-from worker.danmaku import do_workflow
+from workflow.worker import do_workflow
 from workflow.danmaku import get_file_start
 from workflow.video import get_video_real_duration
 from exception.danmaku import DanmakuException
diff --git a/controller/api/workflow_blueprint.py b/controller/api/workflow_blueprint.py
index d37e87e..8944bdd 100644
--- a/controller/api/workflow_blueprint.py
+++ b/controller/api/workflow_blueprint.py
@@ -3,7 +3,7 @@ import threading
 from flask import Blueprint, jsonify
 
 from model.Workflow import Workflow
-from worker.danmaku import do_workflow
+from workflow.worker import do_workflow
 from model import db
 
 blueprint = Blueprint("api_workflow", __name__, url_prefix="/api/workflow")
diff --git a/worker/danmaku.py b/workflow/worker.py
similarity index 100%
rename from worker/danmaku.py
rename to workflow/worker.py