Skip to content

Commit 9fc347f

Browse files
authored
Debug
Removed notification for task start in analysis.py.
1 parent 0daecb4 commit 9fc347f

File tree

1 file changed

+0
-9
lines changed

1 file changed

+0
-9
lines changed

app/tasks/analysis.py

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -255,15 +255,6 @@ async def batch_analyze_streams_task(self, task_id: str):
255255
logger.warning(f"[Task {task_id}] 创建开始通知失败: {ne}")
256256

257257
# 2. 筛选可分析的流并锁定
258-
streams_to_analyze = []
259-
await notify_task_started(
260-
db=db,
261-
task_id=task_id,
262-
task_name=task_obj.task_name,
263-
task_type=task_obj.task_type,
264-
total=len(stream_ids),
265-
)
266-
267258
async with async_session_maker() as db:
268259
streams_to_analyze = []
269260
for sid in stream_ids:

0 commit comments

Comments
 (0)