我有一个议程工作,每 1 天调用一次 stockSyncServices.startSync() 函数。我需要能够向我的 rest api 端点发送请求,并停止在请求处理程序中执行函数 startSync()。我尝试调用议程.cancel() - 但它只是从数据库中删除作业,并且该函数仍在运行。
agenda.define('sync', { concurrency: 1 }, async () => {
await stockSyncServices.startSync('full')
})