Function deleteLargeValueKeys

apps/sim/background/cleanup-logs.ts:92–130

(keys: string[])

}

async function deleteLargeValueKeys(keys: string[]): Promise<{ deleted: number; failed: number }> {
  if (!isUsingCloudStorage() || keys.length === 0) {
    return { deleted: 0, failed: 0 }
  }

  let result: Awaited<ReturnType<typeof StorageService.deleteFiles>>
  try {
    result = await StorageService.deleteFiles(keys, 'execution')
  } catch (error) {
    logger.error('Failed to bulk delete large execution values:', { error })
    return { deleted: 0, failed: keys.length }
  }

  const failedKeys = new Set(result.failed.map(({ key }) => key))
  const deletedKeys = keys.filter((key) => !failedKeys.has(key))

  if (deletedKeys.length > 0) {
    try {
      await markLargeValuesDeleted(deletedKeys)
    } catch (error) {
      logger.error('Failed to mark large execution values as deleted:', { error })
      return { deleted: 0, failed: result.failed.length + deletedKeys.length }
    }
  }

  for (const { key, error } of result.failed) {
    logger.error(`Failed to delete large execution value ${key}:`, { error })
  }

  for (const key of deletedKeys) {
    try {
      await deleteFileMetadata(key)
    } catch (metadataError) {
      logger.error(`Failed to delete large execution value metadata ${key}:`, { metadataError })
    }
  }

  return { deleted: deletedKeys.length, failed: result.failed.length }
}

async function cleanupLargeExecutionValues(
  workspaceIds: string[],