Function clearInPausedExecutions

apps/sim/lib/credentials/deletion.ts:165–193

(
  credentialId: string,
  workspaceId: string,
  needle: string
)

}

async function clearInPausedExecutions(
  credentialId: string,
  workspaceId: string,
  needle: string
): Promise<void> {
  const rows = await db
    .select({
      id: schema.pausedExecutions.id,
      executionSnapshot: schema.pausedExecutions.executionSnapshot,
    })
    .from(schema.pausedExecutions)
    .innerJoin(schema.workflow, eq(schema.workflow.id, schema.pausedExecutions.workflowId))
    .where(
      and(
        eq(schema.workflow.workspaceId, workspaceId),
        sql`${schema.pausedExecutions.executionSnapshot}::text LIKE ${needle}`
      )
    )

  for (const row of rows) {
    const next = clearCredentialInValue(row.executionSnapshot, credentialId)
    if (next.changed) {
      await db
        .update(schema.pausedExecutions)
        .set({ executionSnapshot: next.value, updatedAt: new Date() })
        .where(eq(schema.pausedExecutions.id, row.id))
    }
  }
}

async function clearInWorkflowCheckpoints(
  credentialId: string,