( opts?: SchedulerLockOptions, )
| 176 | * Release the scheduler lock if the current session owns it. |
| 177 | */ |
| 178 | export async function releaseSchedulerLock( |
| 179 | opts?: SchedulerLockOptions, |
| 180 | ): Promise<void> { |
| 181 | unregisterCleanup?.() |
| 182 | unregisterCleanup = undefined |
| 183 | lastBlockedBy = undefined |
| 184 | |
| 185 | const dir = opts?.dir |
| 186 | const sessionId = opts?.lockIdentity ?? getSessionId() |
| 187 | const existing = await readLock(dir) |
| 188 | if (!existing || existing.sessionId !== sessionId) return |
| 189 | try { |
| 190 | await unlink(getLockPath(dir)) |
| 191 | logForDebugging('[ScheduledTasks] released scheduler lock') |
| 192 | } catch { |
| 193 | // Already gone. |
| 194 | } |
| 195 | } |
| 196 |
no test coverage detected