(
id: string,
probeKey: string,
createdMs: number,
)
| 2521 | const MIN = 60 * 1000; |
| 2522 | |
| 2523 | function pendingRow( |
| 2524 | id: string, |
| 2525 | probeKey: string, |
| 2526 | createdMs: number, |
| 2527 | ): CreatedJobRow { |
| 2528 | return { |
| 2529 | ...jobView({ id, probe_key: probeKey }), |
| 2530 | payload: samplePayload({ probeKey }), |
| 2531 | created: new Date(createdMs).toISOString(), |
| 2532 | }; |
| 2533 | } |
| 2534 | |
| 2535 | it("claims-then-deletes pending jobs older than expiryPeriods × the (default) family period", async () => { |
| 2536 | const stale = pendingRow("old", "d6:a", T - 4 * HOUR); // > 3 × 60min |
no test coverage detected
searching dependent graphs…