(id, error, retryAfterMs)
| 477 | } |
| 478 | |
| 479 | deferRetry(id, error, retryAfterMs) { |
| 480 | const delay = Math.max(1_000, Number.isFinite(Number(retryAfterMs)) ? Number(retryAfterMs) : 60_000); |
| 481 | this._appendUpdate(id, { |
| 482 | status: 'pending', |
| 483 | next_retry_at: Date.now() + delay, |
| 484 | error: error || null, |
| 485 | }); |
| 486 | } |
| 487 | |
| 488 | list({ type, direction, status, limit, offset } = {}) { |
| 489 | if (!type) throw new Error('type is required for list()'); |