(row: ExecRow)
| 98 | } |
| 99 | |
| 100 | const parseExec = (row: ExecRow): ExecState => ({ |
| 101 | executionId: row.execution_id, |
| 102 | workflowName: row.workflow_name, |
| 103 | payload: row.payload, |
| 104 | parent: row.parent ?? undefined, |
| 105 | status: row.status, |
| 106 | suspended: row.suspended !== 0, |
| 107 | interrupted: row.interrupted !== 0, |
| 108 | completedResult: row.completed_result ?? undefined, |
| 109 | worker: row.worker ?? undefined, |
| 110 | leaseExpiresAt: row.lease_expires_at ?? undefined, |
| 111 | etag: row.etag |
| 112 | }) |
| 113 | |
| 114 | // --- Storage codecs --------------------------------------------------------- |
| 115 | // Values flowing through the engine's activity / deferred boundary are already |
no outgoing calls
no test coverage detected
searching dependent graphs…