Function deleteExecutionFiles

apps/sim/background/cleanup-logs.ts:50–84

(files: unknown, stats: FileDeleteStats)

const LARGE_VALUE_TOMBSTONE_RETENTION_HOURS = 30 * 24

async function deleteExecutionFiles(files: unknown, stats: FileDeleteStats): Promise<void> {
  if (!isUsingCloudStorage() || !files || !Array.isArray(files)) return

  const keys = Array.from(
    new Set(files.filter((f) => f && typeof f === 'object' && f.key).map((f) => f.key as string))
  )
  stats.filesTotal += keys.length
  if (keys.length === 0) return

  let result: Awaited<ReturnType<typeof StorageService.deleteFiles>>
  try {
    result = await StorageService.deleteFiles(keys, 'execution')
  } catch (error) {
    stats.filesDeleteFailed += keys.length
    logger.error('Failed to bulk delete execution files:', { error })
    return
  }

  const failedKeys = new Set(result.failed.map(({ key }) => key))
  stats.filesDeleted += result.deleted
  stats.filesDeleteFailed += result.failed.length

  for (const { key, error } of result.failed) {
    logger.error(`Failed to delete file ${key}:`, { error })
  }
  for (const key of keys) {
    if (failedKeys.has(key)) continue
    try {
      await deleteFileMetadata(key)
    } catch (metadataError) {
      stats.filesDeleteFailed++
      logger.error(`Failed to delete file metadata ${key}:`, { metadataError })
    }
  }
}

interface LargeValueCleanupStats {
  largeValuesTotal: number