c4181/whisper-worker
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

remove meilisearch logs

Browse source
This commit is contained in:
Christopher Moyer 2024-12-17 23:07:52 -05:00
parent 165521f11d
commit 2743c8ca3c
1 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/main.rs
View file

@ -54,7 +54,6 @@ _|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""| {======|_|"""""|_|"""""
let meilisearch_client = Client::new(&cfg.meilisearch_config.connection_string, Some(&cfg.meilisearch_config.api_key)).expect("Couldn't create meilisearch client"); let meilisearch_client = Client::new(&cfg.meilisearch_config.connection_string, Some(&cfg.meilisearch_config.api_key)).expect("Couldn't create meilisearch client");
let processing_lock = Arc::clone(&processing_lock); let processing_lock = Arc::clone(&processing_lock);
async move { async move {
info!("Consuming mq message");
let delivery = match delivery { let delivery = match delivery {
Ok(Some(delivery)) => delivery, Ok(Some(delivery)) => delivery,
Ok(None) => return, Ok(None) => return,
@ -119,7 +118,6 @@ _|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""| {======|_|"""""|_|"""""
return delivery.ack(BasicAckOptions::default()).await.unwrap(); return delivery.ack(BasicAckOptions::default()).await.unwrap();
} }
}; };
info!("Sent to meilisearch, waiting for task to complete");
match wait_for_task_to_complete(&meilisearch_client, &meilisearch_task).await { match wait_for_task_to_complete(&meilisearch_client, &meilisearch_task).await {
Ok(task) if task.is_failure() => { Ok(task) if task.is_failure() => {
error!("Failed to send message to meilisearch, {}", task.unwrap_failure()); error!("Failed to send message to meilisearch, {}", task.unwrap_failure());
@ -129,7 +127,7 @@ _|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""| {======|_|"""""|_|"""""
} }
_ => {} _ => {}
} }
info!("Meilisearch task completed");
delivery.ack(BasicAckOptions::default()).await.unwrap() delivery.ack(BasicAckOptions::default()).await.unwrap()
} }
} }
@ -160,7 +158,6 @@ async fn write_to_meilisearch(client: &Client, call: Call, transcript: String) -
metadata: call metadata: call
}; };
info!("Sending message to meilisearch");
client client
.index("calls") .index("calls")
.add_documents(&[doc], None) .add_documents(&[doc], None)