This commit is contained in:
24
main.py
24
main.py
@ -39,19 +39,17 @@ def _add_jobs():
|
|||||||
else:
|
else:
|
||||||
logger.info("Job 'heartbeat-job' already exists. Skipped.")
|
logger.info("Job 'heartbeat-job' already exists. Skipped.")
|
||||||
|
|
||||||
if not scheduler.get_job("generate-daily-article-job"):
|
# 需要立即执行一次每日文章生成任务
|
||||||
scheduler.add_job(
|
scheduler.add_job(
|
||||||
job_story_portal.job_generate_daily_article,
|
job_story_portal.job_generate_daily_article,
|
||||||
trigger="interval",
|
trigger="interval",
|
||||||
seconds=86400, # 每天运行一次
|
seconds=86400, # 每天运行一次
|
||||||
id="generate-daily-article-job",
|
id="generate-daily-article-job",
|
||||||
replace_existing=True,
|
replace_existing=True,
|
||||||
next_run_time=datetime.now(), # 启动即执行一次
|
next_run_time=datetime.now(), # 启动即执行一次
|
||||||
misfire_grace_time=60, # 允许错过一分钟内的执行
|
misfire_grace_time=60, # 允许错过一分钟内的执行
|
||||||
)
|
)
|
||||||
logger.info("Job 'generate-daily-article-job' registered.")
|
logger.info("Job 'generate-daily-article-job' registered.")
|
||||||
else:
|
|
||||||
logger.info("Job 'generate-daily-article-job' already exists. Skipped.")
|
|
||||||
|
|
||||||
|
|
||||||
@asynccontextmanager
|
@asynccontextmanager
|
||||||
|
|||||||
Reference in New Issue
Block a user