From 2743c8ca3c27de681103eb6d9ca3e171ee599340 Mon Sep 17 00:00:00 2001 From: Christopher Moyer Date: Tue, 17 Dec 2024 23:07:52 -0500 Subject: [PATCH] remove meilisearch logs --- src/main.rs | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/main.rs b/src/main.rs index c24ba1e..4a1096d 100644 --- a/src/main.rs +++ b/src/main.rs @@ -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 processing_lock = Arc::clone(&processing_lock); async move { - info!("Consuming mq message"); let delivery = match delivery { Ok(Some(delivery)) => delivery, Ok(None) => return, @@ -119,7 +118,6 @@ _|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""| {======|_|"""""|_|""""" 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 { Ok(task) if task.is_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() } } @@ -160,7 +158,6 @@ async fn write_to_meilisearch(client: &Client, call: Call, transcript: String) - metadata: call }; - info!("Sending message to meilisearch"); client .index("calls") .add_documents(&[doc], None)