clean up task locks
This commit is contained in:
@@ -57,6 +57,7 @@ async function drain() {
|
||||
.finally(async () => {
|
||||
delete gActiveTasks[appId];
|
||||
await locks.release(`${locks.TYPE_APP_TASK_PREFIX}${appId}`);
|
||||
await locks.releaseByTaskId(taskId);
|
||||
scheduler.resumeAppJobs(appId);
|
||||
});
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user