(sequence: number)
| 63 | |
| 64 | const body = Buffer.from('row\n', 'utf8') |
| 65 | const meta = (sequence: number) => ({ |
| 66 | drainId: 'd1', |
| 67 | runId: 'r1', |
| 68 | source: 'workflow_logs' as const, |
| 69 | sequence, |
| 70 | rowCount: 1, |
| 71 | runStartedAt: new Date('2025-06-15T12:00:00Z'), |
| 72 | }) |
| 73 | const signal = new AbortController().signal |
| 74 | |
| 75 | const res1 = await session.deliver({ |