This commit is contained in:
4
main.py
4
main.py
@ -74,8 +74,6 @@ async def lifespan(app: FastAPI):
|
|||||||
if scheduler.running:
|
if scheduler.running:
|
||||||
logger.warning("Scheduler already running. Skip start.")
|
logger.warning("Scheduler already running. Skip start.")
|
||||||
else:
|
else:
|
||||||
_add_jobs()
|
|
||||||
|
|
||||||
try:
|
try:
|
||||||
scheduler.start()
|
scheduler.start()
|
||||||
logger.info("APScheduler started.")
|
logger.info("APScheduler started.")
|
||||||
@ -83,6 +81,8 @@ async def lifespan(app: FastAPI):
|
|||||||
logger.exception("Failed to start APScheduler:")
|
logger.exception("Failed to start APScheduler:")
|
||||||
raise
|
raise
|
||||||
|
|
||||||
|
_add_jobs()
|
||||||
|
|
||||||
yield # ---- 应用运行中 ----
|
yield # ---- 应用运行中 ----
|
||||||
|
|
||||||
logger.info("==== Lifespan: shutdown ====")
|
logger.info("==== Lifespan: shutdown ====")
|
||||||
|
|||||||
Reference in New Issue
Block a user