db.insertion.dataset

class DatasetAction(value, names=<not given>, *values, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

APPEND = 'append'

CREATE = 'create'

class DatasetExampleAdditionEvent(dataset_id: int)

Bases: DataManipulationEvent

dataset_id: int

class DatasetKeys(input: FrozenSet[str], output: FrozenSet[str], metadata: FrozenSet[str])

Bases: object

check_differences(column_headers_set: FrozenSet[str]) → None

input: FrozenSet[str]

metadata: FrozenSet[str]

output: FrozenSet[str]

class ExampleContent(input: Dict[str, Any] = <factory>, output: Dict[str, Any] = <factory>, metadata: Dict[str, Any] = <factory>)

Bases: object

input: Dict[str, Any]

metadata: Dict[str, Any]

output: Dict[str, Any]

class RevisionKind(value, names=<not given>, *values, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

CREATE = 'CREATE'

DELETE = 'DELETE'

PATCH = 'PATCH'

async add_dataset_examples(session: AsyncSession, name: str, examples: Iterable[ExampleContent] | Awaitable[Iterable[ExampleContent]], description: str | None = None, metadata: Mapping[str, Any] | None = None, action: DatasetAction = DatasetAction.CREATE) → DatasetExampleAdditionEvent | None

async insert_dataset(session: AsyncSession, name: str, description: str | None = None, metadata: Mapping[str, Any] | None = None, created_at: datetime | None = None) → int

async insert_dataset_example(session: AsyncSession, dataset_id: int, span_rowid: int | None = None, created_at: datetime | None = None) → int

async insert_dataset_example_revision(session: AsyncSession, dataset_version_id: int, dataset_example_id: int, input: Mapping[str, Any], output: Mapping[str, Any], metadata: Mapping[str, Any] | None = None, revision_kind: RevisionKind = RevisionKind.CREATE, created_at: datetime | None = None) → int

async insert_dataset_version(session: AsyncSession, dataset_id: int, description: str | None = None, metadata: Mapping[str, Any] | None = None, created_at: datetime | None = None) → int