Skip to content

Commit 6194bf5

Browse files
committed
Log client idx
1 parent 07b3b36 commit 6194bf5

File tree

1 file changed

+18
-10
lines changed
  • apps/labrinth/src/search/indexing

1 file changed

+18
-10
lines changed

apps/labrinth/src/search/indexing/mod.rs

Lines changed: 18 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ use meilisearch_sdk::indexes::Index;
1414
use meilisearch_sdk::settings::{PaginationSetting, Settings};
1515
use sqlx::postgres::PgPool;
1616
use thiserror::Error;
17-
use tracing::{error, info, instrument, trace};
17+
use tracing::{Instrument, error, info, info_span, instrument, trace};
1818

1919
#[derive(Error, Debug)]
2020
pub enum IndexingError {
@@ -380,20 +380,28 @@ pub async fn add_projects_batch_client(
380380

381381
let mut tasks = FuturesOrdered::new();
382382

383+
let mut id = 0;
384+
383385
client.across_all(index_references, |index_list, client| {
386+
let span = info_span!("add_projects_batch", client.idx = id);
387+
id += 1;
388+
384389
for index in index_list {
385390
let owned_client = client.clone();
386391
let projects_ref = &projects;
387392
let additional_fields_ref = &additional_fields;
388-
tasks.push_back(async move {
389-
update_and_add_to_index(
390-
&owned_client,
391-
index,
392-
projects_ref,
393-
additional_fields_ref,
394-
)
395-
.await
396-
});
393+
tasks.push_back(
394+
async move {
395+
update_and_add_to_index(
396+
&owned_client,
397+
index,
398+
projects_ref,
399+
additional_fields_ref,
400+
)
401+
.await
402+
}
403+
.instrument(span.clone()),
404+
);
397405
}
398406
});
399407

0 commit comments

Comments
 (0)