( key: string | undefined, size: number, referencedKeys: string[], context: LargeValueStoreContext )
| 111 | } |
| 112 | |
| 113 | async function registerPersistedValueOwner( |
| 114 | key: string | undefined, |
| 115 | size: number, |
| 116 | referencedKeys: string[], |
| 117 | context: LargeValueStoreContext |
| 118 | ): Promise<boolean> { |
| 119 | const { workspaceId, workflowId, executionId } = context |
| 120 | if (!key || !workspaceId || !workflowId || !executionId) { |
| 121 | return false |
| 122 | } |
| 123 | |
| 124 | const { registerLargeValueOwner } = await import('@/lib/execution/payloads/large-value-metadata') |
| 125 | return await registerLargeValueOwner( |
| 126 | { |
| 127 | key, |
| 128 | workspaceId, |
| 129 | workflowId, |
| 130 | executionId, |
| 131 | size, |
| 132 | }, |
| 133 | referencedKeys |
| 134 | ) |
| 135 | } |
| 136 | |
| 137 | async function deleteUntrackedPersistedValue(key: string): Promise<boolean> { |
| 138 | try { |
no test coverage detected