* Recovers the workflowId embedded in a large-value storage key * (`execution/{workspaceId}/{workflowId}/{executionId}/ `). Used when the * log row's workflowId has been nulled by workflow deletion.
(key: string | undefined)
| 48 | * log row's workflowId has been nulled by workflow deletion. |
| 49 | */ |
| 50 | function workflowIdFromStorageKey(key: string | undefined): string | undefined { |
| 51 | if (!key) return undefined |
| 52 | const parts = key.split('/') |
| 53 | return parts.length >= 5 && parts[0] === 'execution' ? parts[2] : undefined |
| 54 | } |
| 55 | |
| 56 | /** |
| 57 | * Recursively removes `cost` from trace spans before persistence. Cost lives in |
no outgoing calls
no test coverage detected