1mod connection;
4mod conversions;
5pub mod entities;
6pub mod migrator;
7pub mod ops;
8pub mod pipelines;
9pub mod sync;
10mod traits;
11mod types;
12pub mod uuid_hex;
13
14pub use ops::tutorial_seeder::{
16 TUTORIAL_BASICS_ID, TUTORIAL_PYTHON_DEV_ID, seed_tutorials_if_first_call,
17};
18
19pub use connection::{connect, initialize, sqlite_url_is_in_memory};
20
21pub(crate) fn connection_system_label<C: sea_orm::ConnectionTrait>(db: &C) -> &'static str {
26 use sea_orm::DatabaseBackend;
27 match db.get_database_backend() {
28 DatabaseBackend::Sqlite => "sqlite",
29 DatabaseBackend::Postgres => "postgres",
30 DatabaseBackend::MySql => "mysql",
31 }
32}
33
34pub fn database_system_label(db: &DatabaseConnection) -> &'static str {
41 connection_system_label(db)
42}
43pub use ops::checkpoint::{CheckpointStore, SeaOrmCheckpointStore};
44pub use pipelines::sea_orm_impl::SeaOrmPipelineRunRepository;
45pub use pipelines::{
46 NoopPipelineRunRepository, PipelineRunRepository, PipelineRunWithAttributionRow,
47};
48pub use sea_orm::DatabaseConnection;
49pub use sync::{
50 SeaOrmSyncOperationRepository, SyncOperationRepository, SyncOperationRow, SyncOperationStatus,
51};
52pub use traits::{
53 AclDb, CostByModelRow, DatasetConfigDb, DatasetConfiguration, DatasetConfigurationPatch,
54 DeleteDb, IngestDb, Notebook, NotebookDb, NotebookUpdatePatch, SearchHistoryDb,
55 SessionLifecycleDb, SessionListFilters, SessionListPage, SessionRowWithStatus, SessionStats,
56};
57pub use types::{
58 DatabaseError, GraphEdge, GraphMetrics, GraphNode, PipelineRun, PipelineRunStatus,
59 SearchHistoryEntry, SearchHistoryEntryType, TaskRun,
60};
61
62