Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 5 additions & 1 deletion ampc-anon-stats/src/store/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,10 @@
const ANON_STATS_2D_TABLE_DI: &str = "anon_stats_2d_di";

impl AnonStatsStore {
pub async fn new(postgres_client: &PostgresClient) -> Result<Self> {
pub async fn new(
postgres_client: &PostgresClient,
ignore_missing_migrations: bool,
) -> Result<Self> {
tracing::info!(
"Created anon-stats-mpc-store with schema: {}",
postgres_client.schema_name
Expand All @@ -35,6 +38,7 @@
tracing::info!("Not migrating anon-stats-mpc-store DB in read-only mode");
} else {
sqlx::migrate!("./anon_stats_migrations/")
.set_ignore_missing(ignore_missing_migrations)
.run(&postgres_client.pool)
.await?;
}
Expand Down Expand Up @@ -655,7 +659,7 @@
}

/// Get available face-ampc anon stats entries from the DB for the given origin, up to the given limit.
/// Returns a tuple of (ids, query_ids, Vec<FaceDistance>).

Check warning on line 662 in ampc-anon-stats/src/store/mod.rs

View workflow job for this annotation

GitHub Actions / doc

unclosed HTML tag `FaceDistance`
pub async fn get_available_anon_stats_face(
&self,
origin: AnonStatsOrigin,
Expand Down
Loading