From 3fc21af41e601fbdf4d51b9baf8db454c3270f31 Mon Sep 17 00:00:00 2001
From: jxxghp <jxxghp@gmail.com>
Date: Thu, 8 Jun 2023 18:52:27 +0800
Subject: [PATCH] fix

---
 app/api/endpoints/douban.py | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/app/api/endpoints/douban.py b/app/api/endpoints/douban.py
index 22835685..6bb0552a 100644
--- a/app/api/endpoints/douban.py
+++ b/app/api/endpoints/douban.py
@@ -1,6 +1,4 @@
-from typing import List
-
-from fastapi import APIRouter, Depends, HTTPException
+from fastapi import APIRouter, Depends, HTTPException, BackgroundTasks
 from sqlalchemy.orm import Session
 
 from app import schemas
@@ -12,8 +10,16 @@ from app.db.userauth import get_current_active_superuser
 router = APIRouter()
 
 
+def start_douban_chain():
+    """
+    启动链式任务
+    """
+    DoubanSyncChain().process()
+
+
 @router.get("/sync", response_model=schemas.Response)
 async def sync_douban(
+        background_tasks: BackgroundTasks,
         db: Session = Depends(get_db),
         current_user: User = Depends(get_current_active_superuser)):
     """
@@ -24,5 +30,5 @@ async def sync_douban(
             status_code=400,
             detail="需要授权",
         )
-    DoubanSyncChain().process()
+    background_tasks.add_task(start_douban_chain)
     return {"success": True}