Remove a single job from a context and clean up its dependencies.
(contextId: SchedulerContextId, jobId: unknown)
| 205 | |
| 206 | /** Remove a single job from a context and clean up its dependencies. */ |
| 207 | clearJob(contextId: SchedulerContextId, jobId: unknown): void { |
| 208 | const context = this.contexts.get(contextId) |
| 209 | if (!context) return |
| 210 | |
| 211 | context.jobs.delete(jobId) |
| 212 | context.dependencies.delete(jobId) |
| 213 | context.completed.delete(jobId) |
| 214 | context.queue = context.queue.filter((id) => id !== jobId) |
| 215 | |
| 216 | if (context.jobs.size === 0) { |
| 217 | this.contexts.delete(contextId) |
| 218 | } |
| 219 | } |
| 220 | } |
| 221 | |
| 222 | export const transactionScopedScheduler = new Scheduler() |