diff --git a/worker/danmaku.py b/worker/danmaku.py
index 218dd95..c7e47cf 100644
--- a/worker/danmaku.py
+++ b/worker/danmaku.py
@@ -1,4 +1,3 @@
-import argparse
 import os.path
 from datetime import datetime
 
@@ -24,4 +23,8 @@ def do_workflow(video_file, danmaku_base_file, *danmaku_files):
     print(result)
     encode_video_with_subtitles(video_file, result, new_file_name)
     quick_split_video(new_file_name)
+    # clean files
+    for file in result:
+        os.remove(file)
+    os.remove(new_file_name)