@etohq/workflows-input-dataset-runtime

CSV parsing + dataset import runtime for @etohq/workflows-input-dataset.

Typical Usage

import type { InputSchemaSpec } from "@etohq/workflows-input-schema"
import type { DatasetImportSpec } from "@etohq/workflows-input-dataset"
import { convertCsvToRecords } from "@etohq/workflows-input-dataset-runtime"
import { importCsvRecords } from "@etohq/workflows-input-dataset-runtime"

const records = convertCsvToRecords(csvText)

const res = importCsvRecords({
  schema,
  spec,
  records,
})

if (res.status !== "valid") {
  // res.issues contains row-level and mapping-level validation issues.
}

Notes

• This runtime is pure and deterministic: no network calls, no storage.
• Dataset-level uniqueness is enforced for schema fields with { type: "unique", scope: "dataset" }.