diff --git a/src/main.rs b/src/main.rs index 2ca4266..e4c241f 100644 --- a/src/main.rs +++ b/src/main.rs @@ -118,6 +118,7 @@ _|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""| {======|_|"""""|_|""""" 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()); @@ -127,7 +128,7 @@ _|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""|_|"""""| {======|_|"""""|_|""""" } _ => {} } - + info!("Meilisearch task completed"); delivery.ack(BasicAckOptions::default()).await.unwrap() } } @@ -158,9 +159,10 @@ async fn write_to_meilisearch(client: &Client, call: Call, transcript: String) - metadata: call }; + info!("Sending message to meilisearch"); client .index("calls") - .add_documents(&vec![&doc], None) + .add_documents(&[doc], None) .await }