(exec: RowExecutionMetadata | undefined)
| 194 | * queue (e.g. trigger.dev concurrency backlog) must not run once it |
| 195 | * dequeues. Reads the already-loaded row's exec — no extra query. */ |
| 196 | const cancelledBeforeRun = (exec: RowExecutionMetadata | undefined): boolean => { |
| 197 | if (!isExecCancelled(exec)) return false |
| 198 | logger.info( |
| 199 | `Skipping cell — cancelled before execution (table=${tableId} row=${rowId} group=${groupId})` |
| 200 | ) |
| 201 | return true |
| 202 | } |
| 203 | |
| 204 | // Enrichment groups call a registry function directly instead of running a |
| 205 | // workflow, reusing the same pickup → run → terminal-write status flow. The |
no test coverage detected