salescrm/b/kpi/operate_kpii.dspy
2025-10-27 15:50:44 +08:00

12 lines
451 B
Plaintext

async def operate_kpii(ns={}):
executor = apscheduler.schedulers.asyncio.AsyncIOScheduler(
timezone='Asia/Shanghai',
job_defaults={
"misfire_grace_time": 3600, # 允许存在多久时间的任务数
"max_instances": 200, # 该定时任务允许最大的实例个数
"coalesce": False # 多个任务堆积,是否运行最新的
}
)
ret = await operate_kpii(params_kw)
return ret