db.bulk_inserter

class BulkInserter(db: Callable[[], AsyncContextManager[AsyncSession]], *, cache_for_dataloaders: CacheForDataLoaders | None = None, initial_batch_of_operations: Iterable[Callable[[AsyncSession], Awaitable[DataManipulationEvent | None]]] = (), initial_batch_of_spans: Iterable[Tuple[Span, str]] | None = None, initial_batch_of_evaluations: Iterable[Evaluation] | None = None, sleep: float = 0.1, max_ops_per_transaction: int = 1000, max_queue_size: int = 1000, enable_prometheus: bool = False)

Bases: object

last_updated_at(project_rowid: int | None = None) → datetime | None

class TransactionResult(updated_project_rowids: Set[int] = <factory>)

Bases: object

updated_project_rowids: Set[int]